Kafka - Advanced Stream Processing
When testing a Kafka Streams topology that excludes records with null values, which
TopologyTestDriver approach correctly verifies this filtering?When testing a Kafka Streams topology that excludes records with null values, which TopologyTestDriver approach correctly verifies this filtering?
hard📝 Application Q8 of 15
Step-by-Step Solution
Solution:
Step 1: Understand filtering behavior
The topology should remove records with null values before forwarding.Step 2: Design test approach
Send a mix of null and non-null records to the input topic.Step 3: Verify output
Assert that the output topic contains only the non-null records, confirming filtering.Step 4: Evaluate options
Send records including null values to input topic and assert output topic contains only non-null records correctly describes this approach. Send only non-null records and check output topic for nulls does not test filtering nulls. Send null records and expect an exception fromTopologyTestDriverincorrectly expects exceptions. Send null records and verify they appear unchanged in the output topic contradicts filtering logic.Final Answer:
Send records including null values to input topic and assert output topic contains only non-null records -> Option AQuick Check:
Input nulls, output no nulls [OK]
Quick Trick: Input nulls, expect filtered output [OK]
Common Mistakes:
- Not sending null records to test filtering
- Expecting exceptions on null inputs
- Assuming nulls pass through unchanged
Master "Advanced Stream Processing" in Kafka
Want More Practice?
15+ quiz questions · All difficulty levels · Free
Free Signup - Practice All QuestionsMore Kafka Quizzes