使用 Spring 访问 Kafka Stream State Store

Question

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

如何使用 kafka 流 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());

但我不确定如何获得对 KafkaStreams 对象的访问权限。

Answer 1

自动装配 StreamsBuilderFactoryBean（或以其他方式从应用程序上下文中获取对它的引用）并调用 getKafkaStreams().

使用 Spring 访问 Kafka Stream State Store

Accessing Kafka Stream State Store with Spring

apache-kafka

apache-kafka-streams

spring-kafka