Hector Geraldino created KAFKA-14809:
----------------------------------------
Summary: Fix logging conditional on WorkerSourceTask
Key: KAFKA-14809
URL: https://issues.apache.org/jira/browse/KAFKA-14809
Project: Kafka
Issue Type: Bug
Components: KafkaConnect
Reporter: Hector Geraldino
Assignee: Hector Geraldino
There's an *{{if}}* condition when [committing
offsets|https://github.com/apache/kafka/blob/trunk/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java#L219]
that is referencing the wrong variable, so the statement always evaluates to
{*}true{*}.
It's a subtle bug, which went undetected probably because its only used to log
information about pending committable offsets.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)