we have in our Hadoop cluster 3 Kafka machines,
Kafka machines include the following services
on kafka01:
confluent kafka service
confluent schema registry service
zookeeper service
on kafka02:
confluent kafka service
confluent schema registry service
zookeeper service
on kafka03:
confluent kafka service
confluent schema registry service
zookeeper service
on our Kafka cluster , we have different 34 topics
one of the topic is topic name - `car.to.go`
this topic include 3 replica in Kafka cluster
what we found regarding to schema registry service , is that topic - `car.to.go` have different versions on kafka03 from other machines - `kafka01/02`
so actually we get that versions are not in sync
here is example:
[root@kafka01 ~]# curl -X GET http://kafka01:8081/subjects/car.to.go-value/versions
[1,2,3,4,5,6,7]
[root@kafka01 ~]# curl -X GET http://kafka02:8081/subjects/car.to.go-value/versions
[1,2,3,4,5,6,7]
[root@kafka01 ~]# curl -X GET http://kafka03:8081/subjects/car.to.go-value/versions
[1,2,3,4]
from above info what could be the resewn that versions on kafka03 is diff from kafka01/02
regarding to topic `car.to.go` - what is the right way to fix this issue in way that we get on kafka03 the number versions as - `1,2,3,4,5,6,7`
notes:
all Kafka services and schema registry services and zookeeper services are up and running
links:
https://github.com/confluentinc/schema-registry/blob/master/README.md
https://docs.confluent.io/platform/current/schema-registry/develop/using.html#check-if-a-schema-is-r...
https://kafkawize.com/2019/03/17/commands-for-schemaregistry/
Michael-Bronson
