Spring-Cloud-StreamKafka

Question

我已经建立了一个生产者Spring云流应用程序和Kafka作为活页夹。以下是application.yml：

spring:
cloud:
  stream:
    instanceCount : 1
    bindings:
      output:
        destination: topic-sink
        producer:
           partitionSelectorClass: com.partition.CustomPartition
           partitionCount: 1        
...

我有两个实例（同一个应用程序运行在一个jvm上）作为消费者。以下是application.yml：

spring:  
cloud:
  stream:
    bindings:
      input:
        destination: topic-sink
        group: hdfs-sink
        consumer:
          partitioned: true
...

我对Kafka群体的理解是，对于同一群体中的消费者来说，消息只会被消费一次。假设生产者应用程序产生消息A、B，而同一组中有两个消费者应用程序，则消息A将由消费者1读取，消息B、C将由消费者2读取。然而，我的消费者正在消费相同的消息。我的假设错了吗？

Answer 1

我找到解决办法了，谢谢艾瑞克。对于1个分区和1个使用者。我在spring cloud stream App中分享了针对生产者\消费者的解决方案。制片人：

Spring:Cloud:Stream:instanceCount:1绑定：输出：目的地：主题接收器生产者:PartitionSelectorClass:com.Partition.CustomPartition PartitionCount:1
消费者：

Spring:Cloud:Stream:InstanceIndex:0#0和instanceCount之间-1 instanceCount:1绑定：input：destination：topic-sink group：hdfs-sink consumer:partitioned:true
Kafka:binder:autoaddPartitions:true