Kafka - Streams
Identify the error in this Kafka Streams topology code:
StreamsBuilder builder = new StreamsBuilder();
KStream stream = builder.stream("input");
stream.filter((k,v) -> v.length() > 5);
stream.to("output");
Identify the error in this Kafka Streams topology code: StreamsBuilder builder = new StreamsBuilder(); KStream stream = builder.stream("input"); stream.filter((k,v) -> v.length() > 5); stream.to("output");
medium📝 Debug Q6 of Q15
Step-by-Step Solution
Solution:
Step 1: Check filter usage
Filter returns a new stream but result is not saved or used.Step 2: Check to() call
to() is called on original stream, so filtering has no effect on output.Final Answer:
The filtered stream is not assigned or used before sending to output -> Option BQuick Check:
Filter result must be used before to() [OK]
Quick Trick: Assign filtered stream before to() [OK]
Common Mistakes:
MISTAKES- Ignoring that filter returns a new stream
- Calling to() on unfiltered stream
- Assuming filter modifies stream in place
Master "Streams" in Kafka
Want More Practice?
15+ quiz questions · All difficulty levels · Free
Free Signup - Practice All QuestionsMore Kafka Quizzes