confirm kafka message manually

[nieyanzhai]

how to confirm kafka msg received manually so i can reprocess the msg that failed to process

[reugn]

To use the manual committing strategy, disable automatic commits by setting config.Consumer.Offsets.AutoCommit.Enable = false when creating a Kafka source consumer group. More changes are required to the source connector. One option is to include the session with the message sent to the sink for manual commit using custom logic.
Remember that the session.Commit() call is blocking.