Kafka - Advanced Stream Processing
Identify the error in this Kafka Streams state store initialization code:
StreamsBuilder builder = new StreamsBuilder();
builder.addStateStore(Stores.inMemoryKeyValueStore("store1"));
Identify the error in this Kafka Streams state store initialization code: StreamsBuilder builder = new StreamsBuilder(); builder.addStateStore(Stores.inMemoryKeyValueStore("store1"));
medium📝 Debug Q6 of 15
Step-by-Step Solution
Solution:
Step 1: Check method parameter requirements
addStateStore expects a StoreBuilder object, not a StateStore instance.Step 2: Verify correct usage
Stores.inMemoryKeyValueStore returns a StateStore, so it must be wrapped in a StoreBuilder.Final Answer:
addStateStore requires a StoreBuilder, not a StateStore instance -> Option AQuick Check:
addStateStore needs StoreBuilder [OK]
Quick Trick: Use StoreBuilder with addStateStore, not raw store [OK]
Common Mistakes:
- Passing StateStore instead of StoreBuilder
- Assuming inMemoryKeyValueStore is deprecated
- Thinking store names must match topics
Master "Advanced Stream Processing" in Kafka
Want More Practice?
15+ quiz questions · All difficulty levels · Free
Free Signup - Practice All QuestionsMore Kafka Quizzes