2 comments on “Error Registering Avro Schema | Multiple Schemas In One Topic”

Error Registering Avro Schema | Multiple Schemas In One Topic


org.apache.kafka.common.errors.SerializationException: Error registering Avro schema: {"type":"record","name":"schema1","namespace":"test","fields":[{"name":"Name","type":"string"},{"name":"Age","type":"int"},{"name":"Location","type":"string"}]} Caused by: io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException: Schema being registered is incompatible with an earlier schema; error code: 409 at io.confluent.kafka.schemaregistry.client.rest.RestService.sendHttpRequest(RestService.java:170) at io.confluent.kafka.schemaregistry.client.rest.RestService.httpRequest(RestService.java:188) at io.confluent.kafka.schemaregistry.client.rest.RestService.registerSchema(RestService.java:245) at io.confluent.kafka.schemaregistry.client.rest.RestService.registerSchema(RestService.java:237) at io.confluent.kafka.schemaregistry.client.rest.RestService.registerSchema(RestService.java:232) at io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient.registerAndGetId(CachedSchemaRegistryClient.java:59) at io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient.register(CachedSchemaRegistryClient.java:91) at io.confluent.kafka.serializers.AbstractKafkaAvroSerializer.serializeImpl(AbstractKafkaAvroSerializer.java:72) at io.confluent.kafka.formatter.AvroMessageReader.readMessage(AvroMessageReader.java:158) at…

1 comment on “Avro Communication over TCP Sockets”

Avro Communication over TCP Sockets


Storing/Transferring object is a requirement of most applications. What if there is a need for communication between machine having incompatible architecture. Java Serialization won't work for that. Now, if you are thinking about Serialization Framework then you are right. So,…

0 comments on “Kafka-Avro-Scala-Example”

Kafka-Avro-Scala-Example


This post will show you how to write and read messages in Avro format to/from Kafka. Instead of using with plain-text messages, though, we will serialize our messages with Avro. That will allow us to send much more complex data…