我想使用我的自定义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 文件以便脚本能够识别它？
您需要将反序列化器 jar 放在 Kafka 服务器的“libs”文件夹下。
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
