[
https://issues.apache.org/jira/browse/KAFKA-5567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-5567.
------------------------------------------
Resolution: Fixed
> 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.10.2.0, 0.10.2.1, 0.11.0.0
> Reporter: Konstantine Karantasis
> Assignee: Konstantine Karantasis
> Priority: Blocker
> Fix For: 0.11.0.1, 1.0.0
>
>
> 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)
