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
试了,可以,感谢大佬
你的答案