Kafka - Streams
What will happen if you call builder.stream("topic1").filter((k,v) -> v.contains("error")).to("errors"); in a Kafka Streams topology?
What will happen if you call builder.stream("topic1").filter((k,v) -> v.contains("error")).to("errors"); in a Kafka Streams topology?
medium📝 Predict Output Q5 of Q15
Step-by-Step Solution
Solution:
Step 1: Understand the filter operation
Filter passes only messages where value contains "error".Step 2: Identify the output topic
Filtered messages are sent to the "errors" topic via to() method.Final Answer:
Messages containing 'error' are forwarded to 'errors' topic -> Option AQuick Check:
Filter + to() = filtered messages to 'errors' [OK]
Quick Trick: filter() selects messages; to() sends them out [OK]
Common Mistakes:
MISTAKES- Assuming filter sends all messages
- Thinking filter syntax is invalid
- Confusing output topic with input topic
Master "Streams" in Kafka
Want More Practice?
15+ quiz questions · All difficulty levels · Free
Free Signup - Practice All QuestionsMore Kafka Quizzes