[
https://issues.apache.org/jira/browse/KAFKA-9215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jan Arve Sundt updated KAFKA-9215:
----------------------------------
Priority: Trivial (was: Major)
> Mirrormaker 2.0 (connect-standalone.sh)
> ---------------------------------------
>
> Key: KAFKA-9215
> URL: https://issues.apache.org/jira/browse/KAFKA-9215
> Project: Kafka
> Issue Type: Wish
> Reporter: Jan Arve Sundt
> Priority: Trivial
>
> I'm testing to replicate all topics from one Kafka cluster to replica Kafka
> cluster(active/pasive), with the same topic name, include topic data,
> consumers' offset and configuration settings for topics. I can see topic data
> and consumers' offset, but I am not able to see the configuration settings
> for topic. I also need to have the same name for topic in replica. Can anyone
> explain what I am doing wrong?
>
> Setup for my test is:
> ../bin/connect-standalone.sh worker.properties
> connect-mirror-source.properties > worker-connect.log
>
> worker.properties:
> bootstrap.servers=host:port
> key.converter=org.apache.kafka.connect.converters.ByteArrayConverter
> value.converter=org.apache.kafka.connect.converters.ByteArrayConverter
> offset.storage.file.filename=/tmp/connect.offsets
> connect-mirror-source.properties:
> name = local-mirror-source
> connector.class = org.apache.kafka.connect.mirror.MirrorSourceConnector
> topics = test-event
> topics.blacklist = [".*\.internal", ".*\.replica", "__consumer_offsets"]
> source.cluster.alias = upstream
> target.cluster.alias =
> source.cluster.bootstrap.servers = host:port
> target.cluster.bootstrap.servers = host:port
> sync.topic.acls = false
> rename.topics = true
> tasks.max = 1
> key.converter=org.apache.kafka.connect.converters.ByteArrayConverter
> value.converter=org.apache.kafka.connect.converters.ByteArrayConverter
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
