Spring kafka：在Spring Boot中使用交互式查询
在Kafka Streams Spring Boot应用程序中，配置（提供主机和端口信息）和访问交互式查询的“惯用”方式是什么？
访问KafkaStreams实例以访问状态存储的正确方法是什么？
我知道spring cloud stream中的InteractiveQueriesService，但我并不是只在spring Boot中使用spring kafka库。
谢谢你
共有1个答案
Spring Boot自动配置Kafka Streams支持：https://docs.spring.io/spring-boot/docs/current/reference/html/spring-boot-features.html#boot-特色Kafka流。
下面的基础架构隐藏在StreamsBuilderFactoryBean中。有关Apache Kafka文档，请参阅Spring：https://docs.spring.io/spring-kafka/docs/2.6.2/reference/html/#streams-spring
因此，您确实可以使用APIStreamsBuilderFactoryBean.getKafkaStreams（）访问该spawnKafkaStreams实例。
没有对交互式查询的高级支持，但可能可以访问KafkaStreams，例如，继续进行state stores交互应该不会太难。看起来InteractiveQueryService只是KafkaStreams的一个委托。
-
问题内容： 我需要确定调用我的Python脚本的外壳是否处于交互模式。如果它处于交互模式，则程序应将输出通过管道传递到less（1）以便于阅读。如果没有，它应该只将其输出打印到stdout，以便将其通过管道传输到打印机，文件或其他寻呼机。 在shell脚本中，我将检查是否定义了提示变量$ PS1，或者在$-变量中存储的标志中寻找-i选项。 从Python内部测试交互性的首选方法是什么？ 问题答案：
-
原文：Using matplotlib in a python shell 警告 该页面的内容已严重过时。 默认情况下，matplotlib 将绘图延迟到脚本结束，因为绘图可能是开销大的操作，并且你可能不想在每次更改单个属性时更新绘图，而是只在所有属性更改后更新一次。 但是在 python shell 中工作时，通常需要用每个命令更新绘图，例如，在更改xlabel()或一行的标记样式之后。 虽然这
-
问题内容： 只是想知道，是否有可能单独使用PHP创建一个交互式shell。我的意思是您在数据库，python等方面拥有类似的东西。 如果是，怎么办？ 问题答案： 是的，有可能。为了进行交互，该程序必须能够等待并从 stdin中 读取用户输入。在PHP中，您可以通过向打开文件描述符来从 stdin中 读取。从一个不同的问题的答案中获得，这是PHP中的交互式用户提示的示例（当然是从命令行运行时）： 当
-
原文：Interactive navigation 所有图形窗口都带有导航工具栏，可用于浏览数据集。 以下是工具栏底部的每个按钮的说明： Home（首页）、Forward（前进）和Back（后退）按钮： 这些类似于 Web 浏览器的前进和后退按钮。 它们用于在之前定义的视图之间来回浏览。 它们没有意义，除非你已经使用平移和缩放按钮访问了其他地方。 这类似于尝试在访问新页面之前单击 Web 浏览器上
-
我想在事务中使用SpringKafka，但我真的不明白应该如何配置它以及它是如何工作的。 这是我的配置 此配置用于事务id前缀为的DefaultKafkaProducerFactory： 问题一： 我应该如何选择这个交易ID前缀？如果我理解正确，这个前缀被Spring用来为创建的每个生产者生成一个事务性id。 为什么我们不能只使用"UUID。随机UUID（）？ 问题二： 如果生产者被销毁，它将生成
-
我在GET api中有多个查询参数（如姓名、年龄、性别、位置等…n个数字）。现在我需要使用这些查询值来查询我的mongo数据库。现在用户可以发送从0到n的查询参数。 我正在尝试使用类似的东西 或者 但问题是，考虑到用户可以发送的所有排列和组合，我将不得不编写多个查询。有没有更好的方法来做到这一点？