Hello every one,
I'm using MM2 to replicate topics from one cluster to an other (ok,
nothing strange for now), BUT... I also would like to deserialize
message from source to destination (only value of topic).
I have something like (replication.factor=1 because it is a POC):
===== mm2.properties =====
plugin.path=/tmp/confluentinc-kafka-connect-avro-converter-7.5.2/lib/
replication.factor = 1
offset-syncs.topic.location = target
checkpoints.topic.replication.factor=1
heartbeats.topic.replication.factor=1
offset-syncs.topic.replication.factor=1
offset.storage.replication.factor=1
status.storage.replication.factor=1
config.storage.replication.factor=1
client.id = defaultClientId
tasks.max = 1
topics = .*
groups = .*
clusters = A, B
A.bootstrap.servers = srvkfk01:9092
A.client.id = mm2-A-clientId
A.group.id = mm2-A-groupId
A.name = mm2-A-name
A.security.protocol = PLAINTEXT
A.value.deserializer=io.confluent.connect.avro.AvroConverter
A.value.schema.registry.url=https://api.schemaregistry.domain.com/
B.bootstrap.servers = srvkfk02:9094
B.client.id = mm2-B-clientId
B.group.id = mm2-B-groupId
B.name = mm2-B-name
B.security.protocol = PLAINTEXT
A->B.enabled = true
===== END mm2.properties =====
and I'm starting with:
export
CLASSPATH="/tmp/confluent-${CONFLUENT_VERSION}/share/java/schema-registry/:/tmp/confluent-${CONFLUENT_VERSION}/share/java/ksqldb:/tmp/confluent-7.5.2/share/java/ksqldb/kafka-schema-registry-client-7.5.2.jar"
export
CLASSPATH="${CLASSPATH}:/tmp/confluentinc-kafka-connect-avro-converter-7.5.2/lib/"
"/kafka/server/kafka/bin/connect-mirror-maker.sh"
/kafka/config/mm2.properties
=> And the result is that there is no mention of AvroConverter.
I'm looking for help.
Thanks in advance.
