Доступ к государственному магазину Kafka Stream с помощью Spring

Question

Ссылка на 4.2.6 этого документа https://docs.spring.io/spring-kafka/reference/htmlsingle/#kafka-streams

Как получить доступ к государственным магазинам с помощью поддержки пружины kafka stream?

Без весны ты мог бы обойтись?

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

Но я не уверен, как получить доступ к объекту KafkaStreams.

Answer 1

Автоматически подключите StreamsBuilderFactoryBean (или иным образом получите ссылку на него из контекста приложения) и вызовите getKafkaStreams().