apache-kafka - kafka-console-consumer 自定义解串器

Question

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

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

但它无法找到我的自定义类...

Exception in thread "main" java.lang.ClassNotFoundException: My.Custom.KafkaDeserializer

如何引用适当的 jar 文件以便脚本能够识别它？

Answer 1

您需要将解串器 jar 放在 Kafka 服务器的“libs”文件夹下。