[GitHub] [kafka] AnamikaN opened a new pull request #11328: Fixed code so user can use config.properties.exclude to exclude prope…

[GitBox <gi...@apache.org>]

AnamikaN opened a new pull request #11328:
URL: https://github.com/apache/kafka/pull/11328


   Objective - Use MM2 (kafka connect in distributed cluster) for data migration between cluster hosted in private data center and aws msk cluster.
   
   Steps performed -
   
   Started kafka-connect service.
   Created 3 MM2 connectors (i.e. source connector, checkpoint connector and heartbeat connector). Curl commands used to create connectors are in the attached file.  To exclude certain config properties while topic replication, we are using the 'config.properties.exclude' property in the MM2 source connector.
   Expected -
   
   Source topic 'dev.portlandDc.anamika.helloMsk' should be successfully created in destination cluster.
   
   Actual -
   
   Creation of the source topic 'dev.portlandDc.anamika.helloMsk' in destination cluster fails with an error. Error is
   
   [2021-08-06 06:13:40,944] WARN [mm2-msc|worker] Could not create topic dev.portlandDc.anamika.helloMsk. (org.apache.kafka.connect.mirror.MirrorSourceConnector:371)
   org.apache.kafka.common.errors.InvalidConfigurationException: Unknown topic config name: confluent.value.schema.validation
   
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org