小编Kev*_*eus的帖子

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