[
https://issues.apache.org/jira/browse/KAFKA-8226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ernestas Vaiciukevičius updated KAFKA-8226:
-------------------------------------------
Description:
Currently when MirrorMaker moves data between topics with records with null
keys - it shuffles records between destination topic's partitions. Sometimes
it's desirable to try preserving the original partition.
Related PR adds new command line option to do that:
When partition.to.partition=true MirrorMaker retains the partition number when
mirroring records even without the keys.
When using this option - source and destination topics are assumed to have the
same number of partitions.
was:
Currently when MirrorMaker moves data between topics with records with null
keys - it shuffles records between destination topic's partitions. Sometimes
it's desirable trying to preserve the original partition.
Related PR adds new command line option to do that:
When partition.to.partition=true MirrorMaker retains the partition number when
mirroring records even without the keys.
When using this option - source and destination topics are assumed to have the
same number of partitions.
> New MirrorMaker option partition.to.partition
> ---------------------------------------------
>
> Key: KAFKA-8226
> URL: https://issues.apache.org/jira/browse/KAFKA-8226
> Project: Kafka
> Issue Type: Improvement
> Components: core
> Reporter: Ernestas Vaiciukevičius
> Priority: Major
>
> Currently when MirrorMaker moves data between topics with records with null
> keys - it shuffles records between destination topic's partitions. Sometimes
> it's desirable to try preserving the original partition.
> Related PR adds new command line option to do that:
> When partition.to.partition=true MirrorMaker retains the partition number
> when mirroring records even without the keys.
> When using this option - source and destination topics are assumed to have
> the same number of partitions.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
