Kafka - with Java/Python
You want to ensure that your Kafka producer sends messages synchronously and waits for acknowledgment before proceeding. Which method should you use instead of
send()?You want to ensure that your Kafka producer sends messages synchronously and waits for acknowledgment before proceeding. Which method should you use instead of send()?
hard🚀 Application Q9 of Q15
Step-by-Step Solution
Solution:
Step 1: Understand send() behavior
send() is asynchronous and returns a Future object.Step 2: Use get() on Future to block
Calling get() on the Future returned by send() blocks until the send completes, making it synchronous.Final Answer:
Use send().get() to block until the send completes -> Option BQuick Check:
send().get() makes send synchronous [OK]
Quick Trick: Call get() on send() Future to wait synchronously [OK]
Common Mistakes:
MISTAKES- Assuming sendSync() exists
- Using flush() incorrectly
- Blocking inside callback
Master "with Java/Python" in Kafka
Want More Practice?
15+ quiz questions · All difficulty levels · Free
Free Signup - Practice All QuestionsMore Kafka Quizzes