Re: Kafka Sink Key and Value Avro Schema Usage Issues

Hi Ghiy, I am not quite sure about your actual problem, why the schema is not generated as expected. I also needed to work with the Kafka keys in the business logic, therefore I found a way to deserialize and serialize the key along with the event itself by overriding KafkaRecord[De]Serialization

RE: Kafka Sink Key and Value Avro Schema Usage Issues

Also forgot to attach the information regarding how did I convert the avro objects to bytes in the approach that I took with deprecated kafka producer. protected byte[] getValueBytes(Value value) { DatumWriter valWriter = new SpecificDatumWriter( Value.getSchema());