使用Spring访问Kafka Stream State Store

Question

引用此doc https://docs.spring.io/spring-kafka/reference/htmlsingle/#kafka-streams的4.2.6

如何使用kafka stream spring支持访问州商店？

没有春天，你可以做到吗？

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());

但我不确定如何访问Kafka Streams对象。

Answer 1

自动装载StreamsBuilderFactoryBean（或者从应用程序上下文中获取对它的引用）并调用getKafkaStreams()。