发送Kafka消息的更好方法：JsonNode或Map？
我对穿春靴的Kafka还不熟悉。
我们可以在Json/String/Streams/JsonNode/Map中发送kafka消息。所以现在在我的项目中，我想将Map发送给我的一个消费者。
因此，作为第一步，我们将把map转换为JsonNode，然后发送JsonNode。在consumer，我们将把这个JsonNode反序列化为map，然后使用。
我试图发送地图，我可以通过Kafka发送。在consumer时，我得到的是Json字符串。
所以我的问题是，在我的需求中，哪种是实现的最佳方式？
共有1个答案
-
我有一个应用程序，它定期生成原始JSON消息数组。我能够使用avro-tools将其转换为Avro。我这样做是因为由于Kafka-Connect JDBC接收器的限制，我需要消息包含模式。我可以在记事本上打开这个文件，看到它包括模式和几行数据。 现在，我想将其发送到我的中央Kafka代理，然后使用Kafka Connect JDBC接收器将数据放入数据库。我很难理解我应该如何将这些Avro文件发送
-
我正在将SpringWebSocket 4.2.4与sockjs和stomp一起使用，并试图在异步任务中从服务器向所有订阅者发送消息，但运气不佳 我的班级是： 但是订阅者没有得到消息 有什么帮助吗？我做错了什么：( *编辑* 我的消息代理： 当我订阅时： 谢谢 **编辑2：** 谢谢你帮我解决这个问题：）
-
如何使用新的Spring Cloud Stream Kafka功能模型发送消息？ 不推荐的方式是这样的。 但是我如何以函数式风格发送消息呢？ 应用yml公司 我会自动连接MessageChannel，但对于process、process-out-0、output或类似的东西，没有MessageChannel Bean。或者我可以用供应商Bean发送消息吗？谁能给我举个例子吗？谢谢！
-
我试图使用谷歌云计算引擎VM实例作为Kafka消费者。我发现虚拟机阻止了来自任何外部计算机的通信，我成功地设置了防火墙规则，从本地计算机访问虚拟机。 我能够在云虚拟机实例上创建和列出主题。但我无法收发Kafka主题的信息。它抛出超时异常。 我使用telnet检查端口是否打开，并获得了端口的转义序列（9092）。 当我尝试使用另一个云虚拟机实例实现相同的事情时，我能够执行所有kafka操作。（发送/
-
如何在Kafka中发送同步消息 实现这一点的一种方法是设置properties参数 。 但是我想知道是否有一种甚至直接或替代的方式在Kafka中发送同步消息。（比如producer.sync发送（...）等等）。
-
我正在使用kafka java客户端和kafka服务器。 我的代码： Kafka马纳格 当我的循环长度如果在1000左右（在类)时，我就能成功地向Kafka主题发送数据。 但当我的循环长度为1或小于10时，我无法向Kafka主题发送数据。注意我没有得到任何错误。 根据我的发现，如果我想发送一个单一的消息到Kafka主题，根据这个程序我得到了成功的消息，但从来没有得到一个关于我的主题的消息。 但是如