[
https://issues.apache.org/jira/browse/KAFKA-9482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17074132#comment-17074132
]
Rens Groothuijsen commented on KAFKA-9482:
------------------------------------------
[~grinfeld] It works for me. The default source topic refresh interval is 10
minutes, though, could it be that not enough time had passed yet for a refresh?
> mirror maker 2.0 doesn't replicates (create topic) created automatically by
> producing messages
> ----------------------------------------------------------------------------------------------
>
> Key: KAFKA-9482
> URL: https://issues.apache.org/jira/browse/KAFKA-9482
> Project: Kafka
> Issue Type: Bug
> Components: mirrormaker
> Affects Versions: 2.4.0
> Reporter: Mikhail Grinfeld
> Priority: Minor
>
> I have 2 kafka (3 brokers each) clusters and MirrorMaker instance. (built
> with docker and docker-compose)
> Both cluster is defined to create topics automatically (no
> auto.create.topics.enable in conf and default, at least as it appears in
> docs, is true).
> If topic created on source cluster before MirrorMaker starts, everything
> works as expected: producig messages to source cluster, causes replication to
> destination cluster.
> If topic doesn't exist on source cluster, when starting to produce messages,
> it created in source cluster, but not in destination - and no replication
> performed.
>
> Using following mm2.properties:
> {code:java}
> # mm2.propertiesclusters=src,dest
> src.bootstrap.servers=kafka-1:9092,kafka-2:19092,kafka-3:29092
> dest.bootstrap.servers=kafka-4:39092,kafka-5:49092,kafka-6:59092
> src->dest.enabled=true
> src->dest.topics=.*
> {code}
> and running MirrorMaker with
> {code:java}
> connect-mirror-maker /etc/mm2.properties --clusters src dest
> {code}
> Note:
> when I am using Kafka-Streams to read from initial topic, there are few
> KTable topics created automatically by Kafka-Stream - and these topics
> created OK (of course, when initial topic created at the beginning)
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
