我可以在哪个文件中增加 Kafka 的最大消息大小? (我正在发送 String,byte[] 的记录,当我发送 770kb 的 byte[] 时,Kafka 没有发送消息)
最佳答案
在kafka 0.11.0中需要设置以下四个配置选项
经纪人配置选项(details):
message.max.bytes - Kafka 允许的最大记录批大小。
replica.fetch.max.bytes - 尝试为每个分区获取的消息的字节数。
生产者配置选项(details):
- max.request.size - 请求的最大大小(以字节为单位)。建议将该值与 (message.max.bytes) 匹配。
消费者配置选项(details):
- max.partition.fetch.bytes - 服务器返回的每个分区的最大字节数。应该大于 max.message.size 以便消费者可以读取代理发送的最大消息。
关于java - 在哪里设置 Apache Kafka 中的最大消息大小?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/50207715/