Konstantine Karantasis created KAFKA-5567: ---------------------------------------------
Summary: With transformations that mutate the topic-partition committing offsets should to refer to the original topic-partition Key: KAFKA-5567 URL: https://issues.apache.org/jira/browse/KAFKA-5567 Project: Kafka Issue Type: Bug Components: KafkaConnect Affects Versions: 0.11.0.0, 0.10.2.1, 0.10.2.0 Reporter: Konstantine Karantasis Assignee: Konstantine Karantasis Fix For: 0.11.0.1 When a chain of transformations (SMTs) that mutate a record's topic-partition is applied, then Connect is unable to map the transformed record to its original topic-partition. This affects committing offsets. Currently, in order to reproduce the issue one could use the {{TimestampRouter}} transformation with a sink connector such as the {{FileStreamSinkConnector}}. In this ticket we'll address the issue for connectors that don't manage/commit their offsets themselves. For the connectors that do such management, broader API changes are required to supply the connectors with the necessary information that will allow them to map a transformed record to the original. -- This message was sent by Atlassian JIRA (v6.4.14#64029)