[jira] [Created] (KAFKA-21161) Source-topic changelog store gets the task's last produced offset instead of its last consumed offset when the task writes to its own source topic

["Bill Bejeck (Jira)" <ji...@apache.org>]

Bill Bejeck created KAFKA-21161:
-----------------------------------

             Summary: Source-topic changelog store gets the task's last produced offset instead of its last consumed offset when the task writes to its own source topic
                 Key: KAFKA-21161
                 URL: https://issues.apache.org/jira/browse/KAFKA-21161
             Project: Kafka
          Issue Type: Bug
          Components: streams
            Reporter: Bill Bejeck
            Assignee: Bill Bejeck


When a KTable uses its source topic as its changelog (topology.optimization=all or reuse.ktable.source.topics, or Topology#addReadOnlyStateStore) and the same task also writes to that source topic, StreamTask#checkpointableOffsets() gives the offset the task produced precedence over the offset it consumed:



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