What happens if you write the following code in your producer? producer.send(producerRecord).get()
Using Future.get() to wait for a reply from Kafka will limit throughput.
Limited Time Offer
25%
Off
Currently there are no comments in this discussion, be the first to comment!
Currently there are no comments in this discussion, be the first to comment!