[
https://issues.apache.org/jira/browse/KAFKA-4187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504734#comment-15504734
]
James Cheng commented on KAFKA-4187:
------------------------------------
We do the exact same thing.
MirrorMaker actually has some built in support for this. You can provide it a
MessageHandler jar, which can be used to modify the message after it is
retrieved from the source cluster, but before it is produced into the target
cluster.
Here is an example of how to write one and how to use it:
https://github.com/gwenshap/kafka-examples/tree/master/MirrorMakerHandler
> Adding a flag to prefix topics with mirror maker
> ------------------------------------------------
>
> Key: KAFKA-4187
> URL: https://issues.apache.org/jira/browse/KAFKA-4187
> Project: Kafka
> Issue Type: Improvement
> Components: tools
> Affects Versions: 0.8.2.1, 0.9.0.1, 0.10.0.0, 0.10.0.1
> Reporter: Vincent Rischmann
> Priority: Minor
>
> So I have a setup where I need to mirror our production cluster to our
> preproduction cluster, but can't use the original topic names.
> I've patched mirror maker to allow me to define a prefix for each topic and I
> basically prefix everything with mirror_. I'm wondering if there's interest
> for this feature upstream ?
> I have a patch available for Kafka 0.9.0.1 (what I'm using) and from what
> I've seen it should apply well to Kafka 0.10.0.X too.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
