[jira] [Created] (KAFKA-9215) Mirrormaker 2.0 (connect-standalone.sh)

["Jan Arve Sundt (Jira)" <ji...@apache.org>]

Jan Arve Sundt created KAFKA-9215:
-------------------------------------

             Summary: 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


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)