I have avro schema created.
KafkaProducerConfiguration.java.
If I call
ProducerRecord pR=new ProducerRecord<>(key,topic,null);
KafkaProducerConfiguration.sendProducerRecord(request,pR);
I get error:
TimeoutException.
I have avro schema created.
KafkaProducerConfiguration.java.
If I call
ProducerRecord pR=new ProducerRecord<>(key,topic,null);
KafkaProducerConfiguration.sendProducerRecord(request,pR);
I get error:
TimeoutException.
I figured out the method to handle delete connector which should have tombstone messages.
Set “optional”:true to all properties in avro schema and use Drop$Value to create tombstone message.
Java Service (String,Avro) → Kafka → Connector (delete.enabled=true, Drop$Value) ->SQLServer