我想使用 BinderAwareChannelResolver bean，以便使用在运行时解析的主题名向kafka发送消息。我的问题是 partitionCount 在 BindingProperties 此主题的默认值为1。
当kafka中已经存在此主题时，以及当客户端创建此主题时（分区计数等于 minPartitionCount 配置值）。
如何使此属性反映真实的分区数？
我想使用 BinderAwareChannelResolver bean，以便使用在运行时解析的主题名向kafka发送消息。我的问题是 partitionCount 在 BindingProperties 此主题的默认值为1。
当kafka中已经存在此主题时，以及当客户端创建此主题时（分区计数等于 minPartitionCount 配置值）。
如何使此属性反映真实的分区数？
1条答案
按热度按时间8nuwlpux1#
bindingproperties从不更新以反映物理主题配置；这些属性仅用于配置。
使用2.0，您可以使用
NewBindingCallback<KafkaProducerProperties>要修改动态目标的属性，请参阅文档。