jdbc - kafka-connect：为偏移提交刷新 0 条未完成的消息

Question

请帮我解决这个错误

connect-distributed[889911]: [2021-06-23 12:06:27,945] INFO WorkerSourceTask{id=jdbc_source_oracle-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:482)

配置连接源：

"connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
"tasks.max": "1",
"connection.attempts": "1",
"connection.url": "jdbc:oracle:thin:@IP:1521:SID",
"connection.user": "*****",
"connection.password": "******",
"topic.prefix": "ddb-",
"mode": "bulk",
"query": "SELECT ISU_CD, ISU_NM, UPD_DT FROM TBCB_BND",
"poll.interval.ms": 60000

增加参数“ offset.flush.timeout.ms ”，但无济于事

标签： jdbcapache-kafkaapache-kafka-connect