Spring云流配置选项
大家好，我完全是Spring Cloud Streams框架的新手。
在用于Kafka Streams的spring cloud stream文档中，我可以看到在示例中使用的应用程序yaml/properties文件中引用了前缀为spring.cloud.stream.function.definition等的属性。
我知道Cloud streams使用Cloud函数，但是Cloud streams配置的属性中有一个额外的“Stream”组/块，所以我不确定如何访问列出所有可用属性的完整模板yaml。
共有1个答案
一般Spring Cloud Stream方面和特定Kafka binder主题的文档包含有关可用配置属性的信息。
- 春云流一般配置
- Kafka活页夹配置
- Kafka流绑定器配置
您还可以检查存储所有配置数据的Java类，以获得一个全面的属性列表：
-
null
- org.springframework.cloud.stream.binder.kafka.properties
- org.springframework.cloud.stream.binder.kafka.streams.properties
-
我正在尝试在Spring云数据流中配置DLQ。下面是流定义以及我如何部署它 在自定义转换处理器代码中，我已经提到过 这意味着若消息包含错误，那个么RunTimeException和我想在DLQ中捕获这些消息。但当我运行代码时，似乎没有得到任何名为test tran的Kafka DL队列。 我是否需要设置更多属性来启用DLQ，还是需要更改代码中的某些内容以正确使用DLQ。 自定义转换代码 Trans
-
我试图了解运行批处理任务时通过Spring Cloud数据流WRT数据源配置的预期行为。 Spring批处理数据库表（Batch\u JOB\u EXECUTION等）是否在SCDF数据库本身中？当通过SCDF启动任务时，似乎发生了一些神奇的事情，它在SCDF数据库中创建了这些表，并似乎在使用它们。它似乎正在将SCDF数据源注入我的应用程序？ 我目前在localhost服务器版本2.0.1上运行。
-
我正在使用Spring Cloud Stream和RabbitMQ活页夹。它可以很好地处理字节[]负载和Java本机序列化，但我需要处理JSON负载。 这是我的处理器类。 输入到和输出到是带有Jackson注释的POJO。 如何配置JSON转换策略 消息头应该如何被接受和处理
-
我有三个应用程序，一个是spring云配置服务器点，另一个是spring云配置客户endpoint。我在彼此中配置了spring云总线，以使客户endpoint自动刷新发生更改，但在我运行的应用程序中，出现了如下异常 这是我的spring云服务器配置 这是我的spring云配置服务器pom 这是我的spring云配置客户端配置 这是我的spring云配置客户端pom 此异常不会影响操作的应用程序，
-
spring cloud stream如何将多个Kafka分区分配给属于同一消费者组的反应流？ 我注意到，如果我使用普通的非反应流侦听器，每个线程将被分配到一个分区，这取决于使用者并发配置。然而，在流（流量输入）的情况下，我没有注意到任何这样的并行行为。似乎只定义了一个流来处理来自所有分区的消息。 我的期望是每个Kafka主题分区都有独立的流，即使在由不同线程备份的同一节点上也是如此。
-
我正在使用Spring Cloud Config服务器，能够检测来自git存储库的更改并将其传递给配置客户机。 有两种方法，我已经实现了： null 所以两者都工作得很好，那么使用Spring Cloud Bus有什么好处吗？或者在生产环境中，不使用Spring Cloud Bus会有什么问题吗？因为将需要额外的工作来设置RabbitMQ集群(HA)作为生产中的Spring云总线。 谢谢，大卫