Hi, this is the user mailing list for the Apache Ignite project. This page shows the various Kafka email lists: https://kafka.apache.org/contact.html
Regards, Stephen On Mon, 11 Dec 2023 at 15:11, astronaut37 <astronau...@proton.me> wrote: > Hi Guys, > we have an already running Kakfa Connector Cluster. > I want to add a MirrorSourceConnector with a custom replication policy: > ----- > curl --request POST \ > --url http://localhost:9083/connectors \ > --header 'Accept: application/json' \ > --header 'Content-Type: application/json' \ > --data '{ > "name" : "cluster-source", > "config":{ > "connector.class": "org.apache.kafka.connect.mirror.MirrorSourceConnector", > ... > "replication.policy.class" : "org.example.CustomReplicationPolicy", > ... > } > }' > ----- > This leads to an error: > ----- > { > "error_code": 400, > "message": "Connector configuration is invalid and contains the following > 1 error(s):\nInvalid value org.example.CustomReplicationPolicy for > configuration replication.policy.class: Class > org.example.CustomReplicationPolicy could not be found.\nYou can also find > the above list of errors at the endpoint > `/connector-plugins/{connectorType}/config/validate`" > } > ----- > I added the jar which contains CustomReplicationPolicy to the /lib path > but it won't work. > > How can I use my CustomReplicationPolicy with the MirrorSourceConnector? > I'm using Kafka 2.8. > Setting up the MirrorMaker with /bin/connect-mirror-maker.sh and the jar > file in /lib works, but unfortunately I have to configure the mirror maker > connectors one by one in our enviroment. > > BR > Toni >
