KafkaProducer
send method is used to publish a record to a topic. As you see the signature of
send() method it return a Future.
public
Future<RecordMetadata> send(ProducerRecord<K, V> record, Callback
callback)
public
Future<RecordMetadata> send(ProducerRecord<K, V> record)
We can
call the 'get()' method on the Future instance to make the publishing of
messages synchronous.
Note
Do not
make the message production synchronous in production, it leads to performance
issues.
