[KAFKA-9827] MM2 doesnt replicate data

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 2.4.0, 2.4.1
• Component/s: mirrormaker
• Assignee: Unassigned
• Reporter: Dmitry
• Created: 07/Apr/20 04:31
• Updated: 13/May/20 10:12

Description

I have 2 servers with different node count:

1. 2.4.0 version, 3 nodes, broker port plaintext:9090
2. 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:

 

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

 

When i start MM2 on each clusters created 3 topics:

• heartbeat
• *.internal

And thats all. Nothing to happend.

I watching next ERROR's:

[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)

[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)

[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)

Full log in attach

What i missed ? Help please

Issue Links

• relates to: KAFKA-9376 Plugin class loader not found using MM2