使用Spring访问Kafka Stream State Store

Question

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

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

没有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斯特雷姆的目标。

Answer 1

自动连接StreamsBuilderFactoryBean（或从应用程序上下文中获取对它的引用），并调用getKafkaStreams（）。