[
https://issues.apache.org/jira/browse/KAFKA-2976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mayuresh Gharat resolved KAFKA-2976.
------------------------------------
Resolution: Won't Fix
> Mirror maker dies if we delete a topic from destination cluster
> ---------------------------------------------------------------
>
> Key: KAFKA-2976
> URL: https://issues.apache.org/jira/browse/KAFKA-2976
> Project: Kafka
> Issue Type: Bug
> Components: clients
> Reporter: Mayuresh Gharat
> Assignee: Mayuresh Gharat
>
> In datapipeline,
> 1) Suppose the Mirror Maker is producing to a cluster with Topic T and has
> 128 partitions (Partition 0 to Partition 127) . The default setting on
> creation of a new topic on that cluster is 8 partitions.
> 2) After we delete the topic, the topic gets recreated with 8 partitions
> (Partition 0 to Partition 7).
> 3) The RecordAccumulator has batches for partitions from 9 to 127. Those
> batches get expired and the mirror makers will die to avoid data loss.
> We need a way to reassign those batches (batches for Partition 9 top
> Partition 127) in the RecordAccumulator to the newly created Topic T with 8
> partitions (Partition 0 to Partition 7).
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
