I would like to use the kafka-avro-console-producer with the schema registry. I have big schemas (over 10k chars) and I can't really past them as a command line argument. Besides that I'd like to u...

OS: Ubuntu 18.x docker image (from dockerhub.com, as of 2020-09-25): confluentinc/cp-schema-registry:latest I am exploring the HTTP API for the Confluent Schema Registry. First off, is there a def...

I'm using Kafka & Schema-registry. Defined a schema, using confluent's KafkaAvroSerializer on the producer side. Everything works fine. On the other hand, if a producer publishes the event wit...

First of all, I must say I'm not familiar with confluent. I was following this tutorial: https://www.confluent.io/blog/schema-registry-avro-in-spring-boot-application-tutorial/ and I got stuck. I c...

I'm a noob to Kafka and Avro. So i have been trying to get the Producer/Consumer running. So far i have been able to produce and consume simple Bytes and Strings, using the following : Configuratio...

We use schema registry for storing schemas, and messages are serialised to avro and pushed to kafka topics. Wanted to know, when reading data from consumer, how to find the schema id, for which t...

I'm trying to send a message to my broker, using Avro schema, but "im always getting error: 2020-02-01 11:24:37.189 [nioEventLoopGroup-4-1] ERROR Application - Unhandled: POST - /api/orchestr...

I am looking options to install confluent schema registry, is it possible to download and install registry alone and make it work with existing kafka setup ? Thanks

I want to read data from a confluent cloud topic and then write in another topic. At localhost, I haven't had any major problems. But the schema registry of confluent cloud requires to pass some a...

I have implemented Avro schema in node.js with schema being sent with the message payload. And it is working fine. I am looking if there is any way I can use schema-registry with Kafka-node module....

While running kafka consumer, i am getting following error: Caused by: org.apache.kafka.common.errors.SerializationException: Error deserializing Avro message for id 13 Caused by: org.apache.avro....

I would like to customize the naming strategy of the Avro schema subjects in Spring Cloud Stream Producers, Consumers and KStreams. This would be done in Kafka with the properties key.subject.name...

I am running Kafka via Confluent platform. I have followed the steps as per mentioned, java.net.BindException: Address already in use As per documentation here, https://docs.confluent.io/2.0.0/qui...

After setting up the Kafka Broker cluster and creating few topics, we found that the following two topics are automatically created by Kafka: __consumer_offsets _schema What is the importance a...

There is somethigng I'm trying to understand about how Avro-serialized messages are treated by Kafka and Schema Registry - from this post I've understood the schema ID is stored in an predictable p...

I have a spring application that is my kafka producer and I was wondering why avro is the best way to go. I read about it and all it has to offer, but why can't I just serialize my POJO that I cre...

I am trying to create a Kafka Streams Application which processes Avro records, but I am getting the following error: Exception in thread "streams-application-c8031218-8de9-4d55-a5d0-81c30051a829-...

I have an event sourced application built on top of Kafka. Currently I have one Topic that has multiple message types in it. All serialized/deserialized with JSON. The schema registry from conflue...

I have been trying to connect with kafka-avro-console-consumer from Confluent to our legacy Kafka cluster, which was deployed without Confluent Schema Registry. I provided schema explicitly using ...

We have vanilla apache Kafka setup in current infrastructure and we started logging some data that we want to process using Kafka Connect. Currently we use Avro for our message format, but there's ...

How to use Spring-Kafka to read AVRO message with Confluent Schema registry? Is there any sample? I can't find it in official reference document.

I'm trying to connect to single-node Kafka server through Docker but I am getting the following error: %3|1529395526.480|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bo...

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

I don't have exact idea of key schema, that what it is, and why it must be used as key is auto-generated and we just pass a value(message). For value, we pass a schema to the AVRO Serialiser and t...

I am trying to register an AVRO schema to Schema Registry. The schema contains a record and some fields. I post the schema as JSON to Schema Registry REST API and although the JSON look fine the se...