Spring云流动态目的地partitionCount属性
我想使用BinderAwareChannelResolverbean向Kafka发送带有在运行时解析的主题名称的消息。我的问题是，本主题的BindingProperties中的PartitionCount默认值为1。
当Kafka中已经存在此主题时，以及当客户端创建此主题时（分区计数等于MinPartitionCount配置值），此值并不反映真正的分区数。
如何使此属性反映分区的真实数目？
共有1个答案
BindingProperties从不更新以反映物理主题配置；属性仅用于配置。
在2.0中，您可以使用newbindingcallback
来修改动态目标的属性-请参见文档。
-
我正在开发一个路由器（事件代理）应用程序与Spring云流在Kafka，在功能范式。应用程序从不断输入的主题消耗，映射和过滤消息，然后应该根据一些输入字段将其发送到某个主题（一次只有单个消息，而不是多个结果）。 最好的方法是设置Spring。云流动发送到。输出消息的目标标题？如果是这样，我应该如何为生产者设置绑定？
-
我正在使用Spring Cloud Stream，希望以编程方式创建和绑定通道。我的用例是，在应用程序启动期间，我收到要订阅的Kafka主题的动态列表。然后如何为每个主题创建频道？
-
我们在Spring Cloud Stream上有一个应用程序，它与Project React集成在一起。我们通过在消息标题中设置spring.cloud.stream.sendto.destination来动态设置目标主题并发布消息。我们正在寻找处理错误的情况下，如Kafka服务器断断续续或主题不可用而发布。我们已经实现了@ServiceActivator来处理所有错误。动态设置主题时，Servi
-
我正在尝试使用Spring Cloud Stream处理发送到Azure Event Hub实例的消息。这些消息应该路由到Kafka集群上运行时根据消息内容确定的租户特定主题。出于开发目的，我通过Docker在本地运行Kafka。我对配置时未知的绑定进行了一些研究，发现动态目标解析可能正是我在这个场景中所需要的。 然而，让我的解决方案工作的唯一方法是使用。我宁愿使用动态目标标头，这样处理器就可以被
-
我想知道使用spring时“并发”的确切含义。云流动违约消费者并发属性。 文档（https://docs.spring.io/spring-cloud-stream/docs/Chelsea.RELEASE/reference/html/_configuration_options.html）表示“入站消费者的并发”，这可以通过多种方式解释。 幕后创建了什么类型的线程执行器？ 谢啦！
-
application . properties path . repository =/repository 当我从项目文件夹执行jar文件时，application.properties中定义的路径工作正常，它会创建文件夹。但是如果我从任何其他文件夹执行它，路径是相对于这个文件夹的。 例如 < li>java -jar目标/快照. jar - 我试过classpath：/repoistory，