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)
