Details
Description
There's an if condition when committing offsets that is referencing the wrong variable, so the statement always evaluates to true.
This causes log statements like the following to be spuriously emitted:
[2023-03-14 16:18:04,675] DEBUG WorkerSourceTask{id=job-0} Either no records were produced by the task since the last offset commit, or every record has been filtered out by a transformation or dropped due to transformation or conversion errors. (org.apache.kafka.connect.runtime.WorkerSourceTask:220)
Attachments
Issue Links
- causes
-
KAFKA-13669 Log messages for source tasks with no offsets to commit are noisy and confusing
-
- Resolved
-
- links to