Kafka - with Java/Python
You need to consume messages from two Kafka topics, orders and payments, using a single Java consumer instance. Which code snippet correctly subscribes to both topics?
You need to consume messages from two Kafka topics, orders and payments, using a single Java consumer instance. Which code snippet correctly subscribes to both topics?
hard🚀 Application Q8 of Q15
Step-by-Step Solution
Solution:
Step 1: Understand subscription method
Thesubscribe()method accepts a collection of topic names to subscribe to multiple topics.Step 2: Analyze options
consumer.subscribe(Arrays.asList("orders", "payments")); correctly usesArrays.asListto pass both topics as a list.
consumer.subscribe(Collections.singletonList("orders,payments")); passes a single string with comma, which is incorrect.
consumer.assign(Arrays.asList(new TopicPartition("orders", 0), new TopicPartition("payments", 0))); usesassign()with partitions, which is manual assignment, not subscription.
consumer.subscribe("orders"); consumer.subscribe("payments"); callssubscribe()twice, which overwrites the first subscription.Final Answer:
consumer.subscribe(Arrays.asList("orders", "payments")); -> Option CQuick Check:
Subscribe once with a list of topics. [OK]
Quick Trick: Use subscribe with a list for multiple topics [OK]
Common Mistakes:
MISTAKES- Passing comma-separated string instead of list
- Calling subscribe multiple times overwrites subscription
- Confusing assign() with subscribe()
Master "with Java/Python" in Kafka
Want More Practice?
15+ quiz questions · All difficulty levels · Free
Free Signup - Practice All QuestionsMore Kafka Quizzes