kafka-console-consumer 自定义解串器

Question

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

./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

正如已经说过的，有一个开放的 JIRA（https://issues.apache.org/jira/browse/KAFKA-2526），并且还不能使用自定义反序列化器。