我想用我的习惯 value.deserializer 使用kafka控制台使用者命令行工具时。像这样：
./kafka-console-consumer --bootstrap-server kafka2:29092 \
--property value.deserializer=My.Custom.KafkaDeserializer \
--topic TEST但是找不到我的自定义类。。。
线程“main”java.lang.classnotfoundexception中出现异常：my.custom.kafkadeserializer
如何引用适当的jar文件以便脚本能够识别它？
2条答案
按热度按时间z9smfwbn1#
如前所述，有一个开放的吉拉(https://issues.apache.org/jira/browse/kafka-2526)自定义反序列化程序还不能使用。
hpcdzsge2#
您需要将反序列化器jar放在kafka服务器的“libs”文件夹下。