Kafka Connect Offset Commit Error on AWS MSK


I'm encountering an issue with Kafka Connect deployed on AWS Managed Streaming for Apache Kafka (MSK). Specifically, I'm observing an error related to offset committing when using Kafka Connect sink connectors.

Error Message:

2024-02-12 01:11:26,142 ERROR || WorkerSinkTask{id=XXXXX.public.XXXXX2-0} Commit of offsets threw an unexpected exception for sequence number 2506: {XXXXX.public.XXXXX-0=OffsetAndMetadata{offset=437542, leaderEpoch=null, metadata=''}}


I have Kafka Connect deployed on AWS MSK to stream data into various external systems. The error occurs intermittently during offset committing for sink tasks. Offset committing is critical for ensuring data consistency and fault tolerance in my data pipeline. What I've Tried:

Reviewed Kafka Connect logs, but the error message provides limited insight into the root cause. Verified the configuration settings for Kafka Connect and the sink connectors, ensuring alignment with best practices. Consulted Kafka documentation and online forums for troubleshooting guidance but haven't found a specific solution for this error. Attempted to restart Kafka Connect, but the error persists even after service restarts.

Expectations: I expected offset commits to be performed without errors, ensuring the reliability of my Kafka Connect setup. Given the importance of offset committing for data consistency, I'm seeking guidance on resolving this issue effectively.

asked 2 months ago334 views
1 Answer

Hello there,

From the errors seen in the description, the solution could be adding a "timestamp": "UTC" config as per the github issue https://github.com/confluentinc/kafka-connect-storage-cloud/issues/335 which seems relevant.

Also, the other reason could be with the connector configuration which might require tuning.

To confirm the same, please reach back to us over a support case with all the information such as MSK Connector ARN, Configuration, timestamp of when the issue started.

answered 2 months ago
profile picture
reviewed 15 days ago

You are not logged in. Log in to post an answer.

A good answer clearly answers the question and provides constructive feedback and encourages professional growth in the question asker.

Guidelines for Answering Questions