[
https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847056#comment-16847056
]
Srikala commented on KAFKA-7500:
--------------------------------
[~ryannedolan],
I configured connect mirrormaker for replicating topics between two clusters
on kafka 1.1.1 from source to target. Can you please provide your input to
the following.
# The topics are created with a replication factor 1 in the target cluster
even though the source cluster has replication factor 4. The default
replication factor of the target cluster is 4. Obviously, the topic data is
failing to replicate with the error:
org.apache.kafka.common.errors.NotEnoughReplicasException: Number of insync
replicas for partition target.TEST_TOPIC is [1], below required minimum [2]
Replication works fine , if I manually create the topics in the target cluster
with replication factor 4 before starting the replication.
# I see the following lines in the log:
[2019-05-23 20:50:39,033] WARN [Producer clientId=producer-9] Error while
fetching metadata with correlation id 2079 :
\{source.checkpoints.internal=UNKNOWN_TOPIC_OR_PARTITION}
(org.apache.kafka.clients.NetworkClient:1023)
[2019-05-23 20:50:39,039] WARN [Producer clientId=producer-8] Error while
fetching metadata with correlation id 2175 :
\{heartbeats=UNKNOWN_TOPIC_OR_PARTITION}
(org.apache.kafka.clients.NetworkClient:1023)
How are the topics created: source.checkpoints.internal and heartbeats?
3. Is this the right forum to ask questions during the evaluation?
Thanks!
> MirrorMaker 2.0 (KIP-382)
> -------------------------
>
> Key: KAFKA-7500
> URL: https://issues.apache.org/jira/browse/KAFKA-7500
> Project: Kafka
> Issue Type: New Feature
> Components: KafkaConnect, mirrormaker
> Reporter: Ryanne Dolan
> Priority: Minor
> Fix For: 2.4
>
>
> Implement a drop-in replacement for MirrorMaker leveraging the Connect
> framework.
> [https://cwiki.apache.org/confluence/display/KAFKA/KIP-382%3A+MirrorMaker+2.0]
> [https://github.com/apache/kafka/pull/6295]
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
