使用spring-cloud 1.5.7.RELEASE运行spring-boot Dalston.SR4程序。
自己通过云流documentation进行了工作,尤其是在使用kafka-binder时,但在某些配置方面仍不清楚:


从卡夫卡经纪人那里消费时,我们真的需要设置spring.cloud.stream.{instanceCount,instanceIndex}吗?给定spring.cloud.stream.bindings.<channel>.group,我看不到为什么需要这样做。还是可以肯定地说这两个属性仅在cloud.stream.kafka.bindings.<channel>.autoRebalanceEnabled设置为false时才需要?
为kafka消费者设置cloud.stream.default.consumer.partitioned: true有什么好处?
奖励:spring.cloud.stream.kafka.binder.configuration.auto.offset.resetspring.cloud.stream.kafka.bindings.<channelName>.consumer.startOffset有什么区别?是否只是在后面配置每个通道的偏移量重置?无论如何,这两个都没有被拾取,并且在启动过程中auto.offset.reset值仍报告为earliest

最佳答案

正确;仅在使用手动分区分配时才需要。
消费者方面并不完全;但是在生产者方面,例如,如果您需要严格的订购-例如,如果您希望客户“ foo”的所有“订单”都转到同一个分区;您还需要适当的分区配置。在消费者方面(对于Kafka),这只会确保提供了group
startOffset将覆盖全局设置。这些属性在example here的应用顺序中进行了一些错误修复。您使用的是哪个版本?该修补程序在1.3.0版本中;它也位于1.2.x分支上,但尚未发布;我们需要一个1.2.2.RELEASE才能使用;如果您无法升级到1.3,请为此打开github问题。

关于java - spring-cloud-stream-kafka配置:instanceCount和instanceIndex,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/46729871/

10-09 06:45
查看更多