childe / gohangout

使用 golang 模仿的 Logstash。用于消费 Kafka 数据,处理后写入 ES、Clickhouse 等。
MIT License
1.03k stars 238 forks source link

max.bytes parameter is too small. This size must be at least as large as the maximum message size the server allows or else it is possible for the producer to send messages larger than the consumer can fetch. If that happens, the consumer can get stuck trying to fetch a large message on a certain partition #149

Closed david-zh-cn closed 1 year ago

david-zh-cn commented 3 years ago

image

kafka

image

childe commented 3 years ago

你圈起来的配置,已经够大了,都1G 了。 要么,你先检查一下 Topic 的 max.message.bytes 这个配置是多少?