使用 Spring 访问 Kafka Stream State Store

Question

引用本文档的 4.2.6 https://docs.spring.io/spring-kafka/reference/htmlsingle/#kafka-streams

您如何使用 kafka 流弹簧支持访问状态存储？

没有春天你能做什么？

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