hadoop - 找不到类 'org.apache.hadoop.hive.kafka.KafkaStorageHandler'

Question

错误日志:

FAILED: SemanticException Cannot find class 
'org.apache.hadoop.hive.kafka.KafkaStorageHandler'

我已经将/KAFKA_HOME/libs/*添加到类路径中

这是我的测试代码:

(ID_code string, 
target int ,
var_0 FLOAT, 
var_1 FLOAT,
var_2 FLOAT,
var_3 FLOAT,
var_4 FLOAT)

STORED BY 'org.apache.hadoop.hive.kafka.KafkaStorageHandler'

TBLPROPERTIES(
"kafka.topic" = "test_steam",
"kafka.bootstrap.servers" = "lcoal:8778");

我想我缺少了一些jar文件。但是我在查找KafkaStorageHandler时遇到了麻烦。

Answer 1

我发现我应该下载一个jar并将其放入$ HIVE_HOME / lib文件夹中:
kafka-handler-3.1.0.jar
之后，Hive与Kafka一起工作。