spring-kafka:在spring Boot中使用交互式查询

Question

在Kafka Streams+Spring Boot应用程序中配置(提供主机和端口信息(和访问交互查询的"惯用"方式是什么？

访问KafkaStreams实例以访问状态存储的正确方法是什么？

我知道spring-cloud-stream中的InteractiveQueriesService，但我不打算在Spring Boot中仅使用spring-kafka库。

谢谢

Answer 1

Spring Boot自动配置Kafka Streams支持：https://docs.spring.io/spring-boot/docs/current/reference/html/spring-boot-features.html#boot-以卡夫卡河为特色。

下面的基础设施隐藏在StreamsBuilderFactoryBean中。请参阅Spring for Apache Kafka文档：https://docs.spring.io/spring-kafka/docs/2.6.2/reference/html/#streams-弹簧

因此，您确实可以使用APIStreamsBuilderFactoryBean.getKafkaStreams()访问该派生KafkaStreams实例。

交互查询没有高级支持，但可能有权访问KafkaStreams实例，您应该不会很难进行状态存储交互。看起来InteractiveQueryService只是KafkaStreams的一个委派。