在Apache Kafka中设置最大邮件大小的位置？

Question

在哪个文件中我可以增加Kafka的最大邮件大小？(我正在发送String,byte []的记录,当我发送770kb的byte []时,Kafka不发送消息)

Answer 1

在kafka 0.11.0中,需要设置四个配置选项

Broker配置选项(详情):

1. message.max.bytes - Kafka允许的最大记录批量大小.

2. replica.fetch.max.bytes - 尝试为每个分区获取的消息的字节数.

生产者配置选项(详细信息):

1. max.request.size - 请求的最大大小(以字节为单位).建议将此值与(message.max.bytes)匹配.

消费者配置选项(详情):

1. max.partition.fetch.bytes - 服务器返回的每个分区的最大字节数.应该大于max.message.size,以便消费者可以读取代理发送的最大消息.