如何调整kafka connector中producer的max.request.size?

一如乞人不需要形象 发表于: 2021-06-02   最后更新时间: 2021-06-02 15:21:35   3,139 游览

kafka connector最近有时因为消息体过大,导致报错,让我增大max.request.size

启动方式是distributed,

connect-distributed.sh connect-distributed.properties

请问:

  • 应该在哪配置?

  • 是否可以在call conenctor restful api 时可以通过producer.override.max.request.size改?

  • 还有其他方式吗?比如在connect-distributed.properties里?或者在producer.properties里?

connect-distributed.properties中配置,如下:

producer.max.request.size=15728640

试了,可以,感谢大佬

你的答案

查看kafka相关的其他问题或提一个您自己的问题