正如我所知,默认的kafka消息大小是1mb,目前我需要增加它。
我发现github问题,人们说如何解决它。
结果是配置:
- KAFKA_MESSAGE_MAX_BYTES=100001200
奇怪的是,bitnami官方文档没有KAFKA_MESSAGE_MAX_BYTES
,它适用于bitnami kafka最新版本3.0.0。(我知道使用:最新是不好的做法(
正如我所看到的,有一些类似的东西——KAFKA_MAX_MESSAGE_BYTES
,但被重命名为KAFKA_CFG_MESSAGE_MAX_BYTES
那么,有人能解释为什么我的bitnami kafka支持这个未知变量吗?(还是应该使用另一个变量?
我们在几个版本前将所有变量从KAFKA_*
重命名为KAFKA_CFG_*
。他们现在都应该工作。
然而,max.message.bytes
与message.max.bytes
不同。只有后者是可以使用env-var设置的代理配置。