找不到类'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

我发现有一个罐子，我应该下载并放入 $HIVE_HOME/lib 文件夹中：kafka-handler-3.1.0.jar之后，Hive与kafka合作。