java springcloudstreamkafka配置：instanceCount和instanceIndex

Question

使用spring cloud运行spring boot 1.5.7.RELEASE程序。 我自己通过cloud stream documentation工作，特别是关于kafka活页夹的使用，但在一些配置方面仍不清楚：

1. 当我们从卡夫卡经纪人那里消费时，我们真的需要设置spring.cloud.stream.{instanceCount,instanceIndex}？考虑到spring.cloud.stream.bindings.<channel>.group已设置，我不明白为什么需要这样做。或者可以安全地说，只有设置了cloud.stream.kafka.bindings.<channel>.autoRebalanceEnabledfalse时才需要这两个属性吗

2. 为卡夫卡消费者设置cloud.stream.default.consumer.partitioned: true有什么好处吗

3. 奖励：spring.cloud.stream.kafka.binder.configuration.auto.offset.reset和spring.cloud.stream.kafka.bindings.<channelName>.consumer.startOffset之间有什么区别？是否只是配置每个通道的偏移重置？在任何情况下，这两个值都不会被拾取，并且auto.offset.reset值在启动期间仍然报告为earliest

Answer 1

1. 正确；只有在使用手动分区分配时才需要它

2. 不是在消费者方面；但在生产者方面，例如，如果您需要严格的排序，例如，如果您希望客户“foo”的所有“订单”都转到同一分区；您还需要适当的分区配置。在消费者方面（对于卡夫卡而言），它只会确保提供group

3. startOffset将覆盖全局设置。按照应用这些属性的顺序example here已经有一些错误修复。你用的是什么版本？修复程序在1.3.0版本中；它也在1.2上。x分支，但尚未发布；我们需要1.2.2。发布以供使用；如果你不能升级到1.3，请打开一个github问题