在kafka控制台上无法输入大小超过4095个字符的消息

Question

我试图通过kafka控制台生产者发送消息。但我无法输入超过4095个字符的消息。试图搜索生产者或服务器中是否存在与此相关的任何属性但无效。甚至试图搜索是否存在任何特定于OS的限制或stdin字符限制但没有找到任何内容。

请帮助通过控制台生产者发送大量消息。

Answer 1

我发现了另一种方法。添加一个包含输入的文件，然后将其发送给生产者。使用以下命令：

cat yourFile.xml | kafka-console-producer --broker-list localhost:9092 --topic TopicName

如果您的文件内容是单行的，它会有所帮助。希望，这有帮助。