apache-kafka - kafka-console-producer 忽略值序列化程序？

Question

我需要在我的 Kafka 设置中更改值序列化器/反序列化器(出于测试目的，我一直在使用 IntegerSerializer/IntegerDeserializer)。使用 JAVA API，它完全按预期工作；但是，当使用控制台工具时，它似乎无法正常工作。

我所做的所有故障排除使我得出一个结论:似乎 kafka-console-producer 忽略了 Serializer 选项。我试过 --property value.serializer和 --producer-property value.serializer和 --value-serializer并使用 --producer.config 将其设置在配置中争论。

它不仅无法将数据序列化为整数，它甚至不在乎我是否输入无意义作为参数值。如果我输入 --value-deserializer not.a.real.class，使用 kafka-console-consumer(与它的 IntegerDeserializer 完美配合)它会抛出一个找不到类的异常；然而 --value-serializer not.a.real.class在 kafka-console-producer 上，什么都不做。

在 JAVA API 中的生产者上设置这些值，效果很好(如果我输入无意义作为序列化器类，则会抛出异常)，但在使用 kafka-console-producer 时则不然。

这是我尝试运行控制台生产者的方法之一的示例:

kafka-console-producer --broker-list IPADDRESS:9092 --topic TOPIC --property value.serializer=org.apache.kafka.common.serialization.IntegerSerializer

以及相关消费者:

kafka-console-consumer --bootstrap-server IPADDRESS:9092 --topic TOPIC  --property value.deserializer=org.apache.kafka.common.serialization.IntegerDeserializer

有没有人设法使用命令行工具使其工作？有什么明显的我遗漏了吗？

Answer 1

这是一个 known bug在控制台制作人中。您可以通过传递 --old-producer 来解决它工具的选项。