kafka-console-consumer custom deserializer

Question

我想在使用 kafka-console-consumer 命令行工具时使用我的自定义value.deserializer。 像这样：

./kafka-console-consumer --bootstrap-server kafka2:29092 
--property value.deserializer=My.Custom.KafkaDeserializer 
--topic TEST

但是它找不到我的自定义类...

线程"main"中的异常 java.lang.ClassNotFoundException： My.Custom.KafkaDeserializer

如何引用相应的 jar 文件，以便脚本能够识别它？

Answer 1

你需要把反序列化程序jar放在Kafka服务器的"libs"文件夹下。

Answer 2

如前所述，有一个打开的 JIRA (https://issues.apache.org/jira/browse/KAFKA-2526(，并且还不能使用自定义反序列化程序。