cdc to kafka: error encoding packet: invalid request size

🌞 建议反馈 产品缺陷
22

“invalid request size” 这个错误应该是从这里返回的 ：
https://github.com/IBM/sarama/blob/25c9c1a880e385781e1a39b49f8e7239e3d5e729/encoder_decoder.go#L35
MaxRequestSize 最大是 100MiB：
https://github.com/IBM/sarama/blob/25c9c1a880e385781e1a39b49f8e7239e3d5e729/sarama.go#L106

确实消息大小超过了限制

1 个赞