Exercise: Sending Messages with Callback
Procedure
- Review the available
send
methods in KafkaProducer
- Read the javadoc of KafkaProducer.send​(ProducerRecord<K,V> record, Callback callback)
- Explore Callback interface
- Answer the following questions with regards to the Callback interface:
- What does Callback give when you send a message to an existing topic?
- What happens when sending a message to an unexisting topic?
- Mind the automatic topic creation feature
- Duration: 15 mins