Top "Confluent-schema-registry" questions

Schema Registry provides a store, backed by Kafka, for storing and retrieving Avro schemas.

TimeoutException: Timeout expired while fetching topic metadata Kafka

I have been trying to deploy Kafka with schema registry locally using Kubernetes. However, the logs of the schema registry …

kubernetes apache-kafka apache-zookeeper confluent-schema-registry
What is the use of __consumer_offsets and _schema topics in Kafka?

After setting up the Kafka Broker cluster and creating few topics, we found that the following two topics are automatically …

apache-kafka confluent-schema-registry
KafkaAvroSerializer for serializing Avro without schema.registry.url

I'm a noob to Kafka and Avro. So i have been trying to get the Producer/Consumer running. So far …

java apache-kafka avro confluent-schema-registry
Kafka schema registry not compatible in the same topic

I'm using Kafka schema registry for producing/consuming Kafka messages, for example I have two fields they are both string …

apache-kafka avro confluent-schema-registry
Kafka Streams - SerializationException: Unknown magic byte

I am trying to create a Kafka Streams Application which processes Avro records, but I am getting the following error: …

java apache-kafka avro apache-kafka-streams confluent-schema-registry
Integrating Spark Structured Streaming with the Confluent Schema Registry

I'm using a Kafka Source in Spark Structured Streaming to receive Confluent encoded Avro records. I intend to use Confluent …

apache-spark apache-kafka avro confluent-schema-registry spark-structured-streaming
Kafka Stream with Avro in JAVA , schema.registry.url" which has no default value

I have the following configuration for my Kafka Stream application Properties config = new Properties(); config.put(StreamsConfig.APPLICATION_ID_CONFIG,…

java apache-kafka avro apache-kafka-streams confluent-schema-registry
Unknown magic byte with kafka-avro-console-consumer

I have been trying to connect with kafka-avro-console-consumer from Confluent to our legacy Kafka cluster, which was deployed without Confluent …

apache-kafka avro confluent-platform confluent-schema-registry
Kafka Confluent error - java.net.BindException: Address already in use

I am running Kafka via Confluent platform. I have followed the steps as per mentioned, java.net.BindException: Address already …

apache-kafka confluent-schema-registry
How to pass parameters for a specific Schema registry when using Kafka Avro Console Consumer?

I am trying to use Confluent kafka-avro-console-consumer, but how to pass parameters for Schema Registry to it?

apache-kafka avro confluent-platform confluent-schema-registry