@Slf4j
public class Top10StreamProcessor
{
+ public static final String STORE_NAME= "top10";
+
public final KafkaStreams streams;
return topology;
}
- ReadOnlyKeyValueStore<User, Ranking> getStore(String name)
+ ReadOnlyKeyValueStore<User, Ranking> getStore()
{
- return streams.store(StoreQueryParameters.fromNameAndType(name, QueryableStoreTypes.keyValueStore()));
+ return streams.store(StoreQueryParameters.fromNameAndType(STORE_NAME, QueryableStoreTypes.keyValueStore()));
}
public void start()