I pulled the 2.4 branch from github—version 2.4.1-snapshot of pom.xml. When I packaged it and ran it, I still found the same problem. But the data and offset could be synchronized to the target cluster. | | xinzhuxiansheng | | xinzhuxiansh...@126.com | 签名由网易邮箱大师定制 On 1/7/2020 04:26，Ryanne Dolan<ryannedo...@gmail.com> wrote： I just downloaded the 2.4.0 release tarball and didn't run into any issues. Peter, Jamie, can one of you file a jira ticket if you are still seeing this? Thanks!
Ryanne On Fri, Dec 27, 2019 at 12:04 PM Ryanne Dolan <ryannedo...@gmail.com> wrote: Thanks Peter, I'll take a look. Ryanne On Fri, Dec 27, 2019, 7:48 AM Péter Sinóros-Szabó <peter.sinoros-sz...@transferwise.com.invalid> wrote: Hi, I see the same. I just downloaded the Kafka zip and I run: ~/kafka-2.4.0-rc3$ ./bin/connect-mirror-maker.sh config/connect-mirror-maker.properties Peter On Mon, 16 Dec 2019 at 17:14, Ryanne Dolan <ryannedo...@gmail.com> wrote: Hey Jamie, are you running the MM2 connectors on an existing Connect cluster, or with the connet-mirror-maker.sh driver? Given your question about plugin.path I'm guessing the former. Is the Connect cluster running 2.4.0 as well? The jars should land in the Connect runtime without any need to modify the plugin.path or copy jars around. Ryanne On Mon, Dec 16, 2019, 6:23 AM Jamie <jamied...@aol.co.uk.invalid> wrote: Hi All, I'm trying to set up mirror maker 2.0 with Kafka 2.4.0 however, I'm receiving the following errors on startup: ERROR Plugin class loader for connector 'org.apache.kafka.connect.mirror.MirrorSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@187eb9a8 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) ERROR Plugin class loader for connector 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@187eb9a8 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) ERROR Plugin class loader for connector 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@187eb9a8 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) I've checked the jar file containing these class file is in the class path. Is there anything I need to add to plugin.path for the connect properties when running mirror maker? Many Thanks, Jamie -- - Sini
