Kafka读取读取数据,延迟较长,怎么优化?

subscribeTable(tableName="tab_share17", actionName="device", handler=power14, msgAsTable=true, batchSize=1, throttle=10)
请先 登录 后评论

1 个回答

Juntao Wang

batchSize=1,表示一次处理一条数据。可以尝试将batchSize 改为1000,一次处理1000条数据。throttle=10 表示如果10 s内到达Kafka数据达不到1000条,触发一次消息处理操作。

请先 登录 后评论