You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Maaheen Yasin (Jira)" <ji...@apache.org> on 2024/02/28 10:59:00 UTC

[jira] [Created] (KAFKA-16311) [Debezium Informix Connector Unable to Commit Processed Log Position]

Maaheen Yasin created KAFKA-16311:
-------------------------------------

             Summary: [Debezium Informix Connector Unable to Commit Processed Log Position]
                 Key: KAFKA-16311
                 URL: https://issues.apache.org/jira/browse/KAFKA-16311
             Project: Kafka
          Issue Type: Bug
            Reporter: Maaheen Yasin
         Attachments: connect logs.out

I am using Debezium Informix Source connector and JDBC Sink connector and the below versions of Informix database and KAFKA Connect.

Informix Dynamic Server
14.10.FC10W1X2
Informix JDBC Driver for Informix Dynamic Server
4.50.JC10

KAFKA Version: 7.4.1-ce

 

*Expected Behavior:*

All tasks of the Informix source connector are running, and all messages are being published in the topic. During the DDL Execution, the informix database is put under single user mode and the DDL on the table on which CDC was previously enabled was executed. After the database exits from the single user mode, then the connector should be able to reconnect with the source database and be able to publish messages in the topic for each new event. 

*Actual Behavior:*

All tasks of the Informix source connector are running, and all messages are being published in the topic. During the DDL Execution, the database is put under single user mode and the DDL on the table on which CDC was previously enabled was executed. After the database exits from the single user mode, the source connector is able to reconnect with the database, however, no messages are being published in the topic and the below error is being printed in the KAFKA Connect Logs. 

 

*[2024-02-22 15:54:34,913] WARN [kafka_devs|task-0|offsets] Couldn't commit processed log positions with the source database due to a concurrent connector shutdown or restart (io.debezium.connector.common.BaseSourceTask:349)*

 

The complete KAFKA Connect logs has been attached. Kindly comment on why this issue is occurring and what steps should be followed to avoid this issue or to resolve this issue. 

 

Thanks. 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)