kafka-console-consumer 自定义反序列化器答案

【问题标题】：kafka-console-consumer custom deserializerkafka-console-consumer 自定义反序列化器
【发布时间】：2017-08-09 03:12:28
【问题描述】：

我想在使用 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 文件以便脚本识别它？

【问题讨论】：

你必须将这个类添加到类路径中。此外，即使您这样做，控制台消费者工具仍然无法使用它，因为它是一个已知的错误。见issues.apache.org/jira/browse/KAFKA-2526

标签： apache-kafka kafka-consumer-api

【解决方案1】：

您需要将反序列化器 jar 放在 Kafka 服务器的“libs”文件夹下。

【讨论】：

【解决方案2】：

正如已经说过的那样，有一个已打开的 JIRA (https://issues.apache.org/jira/browse/KAFKA-2526)，还不能使用自定义反序列化器。

【讨论】：

我已经检查了confluent-community-5.1.0-2.11。它尊重--value-deserializer。