Support Questions

Find answers, ask questions, and share your expertise

kafka + schema registry + why versions are not the same

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
0 REPLIES 0