Confirm the connect.name forces the replicated namespace in the destination schema.
./start-cluster.sh
Then add some content
docker-compose exec srcSchemaregistry kafka-avro-console-producer --broker-list srcKafka:19092 --topic topic-test --property schema.registry.url=http://srcSchemaregistry:8085 --property value.schema="$(cat data/schema.json)"
{"field1" : "a0", "field2": "b0"}
Confirm the namespaces are different:
curl http://localhost:8085/subjects/topic-test-value/versions/1/schema | jq
curl http://localhost:8086/subjects/topic-test-value/versions/1/schema | jq
- Stop the consumer (control C)
- Clean the docker cluster
docker-compose down -v
Set the connect.name
schema property as namespace
+ name