我已经配置了各种JDBC接收器连接器,以便将数据从kafka主题流式传输到MySQL表中 . 我注意到,一旦我将 POST 请求发送到Kafka Connect,一些行(约1/3)将被直接插入到相应的表中,然后根本没有进展,几分钟后剩下的行是最后补充道 . 即使对于包含5行数据的非常小的主题,也会发生这种情况(前两个条目立即添加,其余3个在1-2分钟后插入) .

我也试图修改 batch.size 属性的值,没有任何运气 .

你如何解释这种行为,我该如何克服这个问题?