Accessing Kafka Stream State Store with Spring
Clash Royale CLAN TAG#URR8PPP
Accessing Kafka Stream State Store with Spring
Referencing 4.2.6 of this doc https://docs.spring.io/spring-kafka/reference/htmlsingle/#kafka-streams
How do you get access to state stores using kafka stream spring support?
Without spring you could do?
StreamsBuilder builder = ...;
// Start an instance of the topology
KafkaStreams streams = new KafkaStreams(builder, config);
...
// Get the key-value store CountsKeyValueStore
ReadOnlyKeyValueStore<String, Long> keyValueStore =
streams.store("CountsKeyValueStore", QueryableStoreTypes.keyValueStore());
But I am not sure how to gain acess to KafkaStreams object.
1 Answer
1
Autowire the StreamsBuilderFactoryBean
(or otherwise get a reference to it from the application context) and call getKafkaStreams()
.
StreamsBuilderFactoryBean
getKafkaStreams()
By clicking "Post Your Answer", you acknowledge that you have read our updated terms of service, privacy policy and cookie policy, and that your continued use of the website is subject to these policies.