You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Dmitry (Jira)" <ji...@apache.org> on 2020/04/07 04:32:00 UTC
[jira] [Created] (KAFKA-9827) MM2 doesnt replicate data
Dmitry created KAFKA-9827:
-----------------------------
Summary: MM2 doesnt replicate data
Key: KAFKA-9827
URL: https://issues.apache.org/jira/browse/KAFKA-9827
Project: Kafka
Issue Type: Bug
Components: mirrormaker
Affects Versions: 2.4.1, 2.4.0
Reporter: Dmitry
Attachments: mm2.log
I have 2 servers with different node count:
# 2.4.0 version, 3 nodes, broker port plaintext:9090
# 2.4.0 version, 1 nodes, broker port plaintext:9999
I want to transfer data from cluster 1 -> cluster 2 by mirror maker 2.
MM2 configuration:
{code:java}
name = mm2-backupFlow
topics = .*
groups = .*
# specify any number of cluster aliases
clusters = m1-source, m1-backup
# connection information for each cluster
m1-source.bootstrap.servers = 172.17.165.49:9090, 172.17.165.50:9090, 172.17.165.51:9090
m1-backup.bootstrap.servers = 172.17.165.52:9999
# enable and configure individual replication flows
m1-source->m1-backup.enabled = true
m1-soruce->m1-backup.emit.heartbeats.enabled = false
{code}
When i start MM2 on each clusters created 3 topics:
* heartbeat
* *.internal
And thats all. Nothing to happend.
I watching next ERROR's:
{code:java}
[2020-04-07 07:19:16,821] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@1e5f4170 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:165)
{code}
{code:java}
[2020-04-07 07:19:18,312] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@1e5f4170 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:165)
{code}
{code:java}
[2020-04-07 07:19:16,807] ERROR Plugin class loader for connector: 'org.apache.kafka.connect.mirror.MirrorSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@1e5f4170 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:165){code}
Full log in attach
What i missed ? Help please
--
This message was sent by Atlassian Jira
(v8.3.4#803005)