Kafka - Advanced Stream Processing
You want to test a Kafka Streams topology that filters out records with null values before forwarding. Which approach correctly verifies this behavior using
TopologyTestDriver?You want to test a Kafka Streams topology that filters out records with null values before forwarding. Which approach correctly verifies this behavior using TopologyTestDriver?
hard📝 Application Q15 of 15
Step-by-Step Solution
Solution:
Step 1: Prepare test input with null and non-null values
This tests the filter logic by including both cases.Step 2: Verify output topic contents
Assert that only records with non-null values appear in the output topic.Final Answer:
Send records with null and non-null values to input topic, then assert output topic only has non-null values -> Option DQuick Check:
Filter test = input mixed, output filtered [OK]
Quick Trick: Test filters by sending mixed input, check filtered output [OK]
Common Mistakes:
- Expecting null values to appear in output
- Not reading output topic to verify results
- Assuming exceptions occur on null values
Master "Advanced Stream Processing" in Kafka
Want More Practice?
15+ quiz questions · All difficulty levels · Free
Free Signup - Practice All QuestionsMore Kafka Quizzes