spring-kafka：在Spring启动时使用交互式查询

Question

在 Kafka Streams + Spring 引导应用程序中配置（提供主机和端口信息）和访问交互式查询的“惯用”方式是什么？

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

我知道 spring-cloud-stream 中有 InteractiveQueriesService，但我并没有将 spring-kafka 库与 Spring Boot 一起使用。

谢谢

Answer 1

Spring 启动 auto-configures Kafka 流支持：https://docs.spring.io/spring-boot/docs/current/reference/html/spring-boot-features.html#boot-features-kafka-streams.

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

因此，您确实可以使用 API StreamsBuilderFactoryBean.getKafkaStreams().

访问该 spawn KafkaStreams 实例

没有 high-level 对交互式查询的支持，但可能可以访问该 KafkaStreams 实例，继续进行状态存储交互对您来说应该不难。看起来 InteractiveQueryService 只是 KafkaStreams.

的委托