Kafka控制台生产者忽略值序列化器？
我需要更改Kafka设置中的值序列化器/反序列化器（出于测试目的，我一直在使用IntegerSerializer/IntegerDeserializer）。使用javaapi，它完全按照预期工作；但是，当使用控制台工具时，它似乎无法正常工作。
我所做的所有故障排除都让我得出了一个结论：Kafka控制台制作人似乎忽略了序列化程序选项。我尝试了——属性值。序列化程序和生产者属性值。序列化程序和--值序列化程序，并将其设置为带有--生产者的配置。配置参数。
它不仅不能将数据序列化为整数，它甚至不在乎我是否输入废话作为参数值。如果我输入--value-反序列化器not.a.real.class，它将抛出一个类找不到异常；然而--value-序列化器not.a.real.class-控制台-制作人，什么都不做。
在javaapi中的producer上设置这些值，效果很好（如果我输入无意义作为序列化器类，则会引发异常），但在使用kafka控制台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
有没有人设法让这个工作与命令行工具？是不是有什么明显的我遗漏了？
共有1个答案
这是控制台生成器中的一个已知错误。您可以通过将--old producer选项传递给工具来解决此问题。
-
运行kafka生产者时出错
-
我试着写一些关于主题的消息，但是控制台不允许(生产者不等待标准输入)。我也看不到任何错误日志。尽管主题已成功创建。我正在使用: 动物园管理员和Kafka服务器运行良好。我使用的是苹果电脑。可能的问题是什么。我正在关注阿帕奇Kafka文档 http://kafka.apache.org/documentation.html#quickstart。
-
我有一个需要使用Kafka Console Producer发送键值消息的用例。那么如何通过命令实现这一点呢？
-
有没有一种方法让我忽略这些异常并在消费者处移动偏移量？我想，因为我使用手动偏移提交，我有这个问题。有人知道如何配置kafka-avro-serializer-6.0.0.jar来完成我想要的任务吗？ 多谢了。
-
我有一个这样的对象： 我是否可以使用和我的条件来仅在不为负数的情况下包含该值？或者有没有其他的解决办法我可以做到这一点？
-
问题内容： 我目前正在使用杰克逊2.1.4，并且在将对象转换为JSON字符串时忽略字段时遇到了一些麻烦。 这是我的类，它充当要转换的对象： 这是我如何转换它： 这是输出： 如何避免这些空值？我只想获取“订阅”目的所需的信息！ 这正是我要查找的输出： 我还尝试了@JsonInclude（Include.NON_NULL）并将所有变量都设置为null，但是它也不起作用！感谢您的帮助！ 问题答案： 您将