【发布时间】:2018-10-16 21:02:34
【问题描述】:
我可以在哪个文件中增加 Kafka 的最大消息大小? (我正在发送String、byte[]的记录,当我发送770kb的byte[]时,Kafka不发送消息)
【问题讨论】:
-
这个问答可能完全解释了它:stackoverflow.com/questions/21020347/… - 它适用于 Kafka 0.8,但我相信这对于较新版本的 Kafka 仍然是正确的。让我们知道这是否有效,然后我可以将其标记为重复。 (这很好,它只是将其他有同样问题的人指向正确的问题)
-
@ErwinBolwidt 我在生产者中将replica.fetch.max.bytes 设置为1000000,将max.request.size 设置为1000000,在消费者中将max.partition.fetch.bytes 设置为1000000,但消息仍然不是发送
-
还有
message.max.bytes?
标签: java apache-kafka