kafka 问题

🧙 Questions

• 启动kafka内存不足

☄️ Ideas

启动kafka内存不足

sudo vim /opt/kafka/bin/kafka-server-start.sh

export KAFKA_HEAP_OPTS="-Xmx256M -Xms128M"

kafka中断

Caused by: org.apache.kafka.common.errors.RecordTooLargeException: The message is 1649687 bytes when serialized which is larger than 1048576, which is the value of the max.request.size configuration.

vim

buffer.memory=200000000 # 默认33554432
max.request.size=200000000  # 默认1048576
message.max.bytes=200000000 # 默认值1048588
max.partition.fetch.bytes=200000000 # 默认值1048576

🔗 Links

• kafka docs