We are writing a custom sink connector for writing content of a topic with avro messages to a CEPH storage. To do this we are provided with SinkRecords which have a Kafka Connect schema which is a...

I am experiencing a reproducible error while producing Avro messages with reactive kafka and avro4s. Once the identityMapCapacity of the client (CachedSchemaRegistryClient) is reached, serializatio...

My KafkaProducer is able to use KafkaAvroSerializer to serialize objects to my topic. However, KafkaConsumer.poll() returns deserialized GenericRecord instead of my serialized class. MyKafkaProduc...