春云流-消费群体绑定

Question

我的使用者绑定到匿名使用者组，而不是我指定的使用者组。

spring:
  cloud:
    stream:
      html" target="_blank">kafka:
        binder:
          brokers: localhost
          defaultBrokerPort: 9092
          zkNodes: localhost
          defaultZkPort: 2181
        bindings:
          inEvent:
            group: eventin
            destination: event
          outEvent:
            group: eventout
            destination: processevent

我的春靴应用

@SpringBootApplication
@EnableBinding(EventStream.class)
public class ConsumerApplication {
    public static void main(String[] args) {
        SpringApplication.run(ConsumerApplication.class, args);
    }
    @StreamListener(value = "inEvent")
    public void getEvent(Event event){
        System.out.println(event.name);
    }
}

我的输入输出通道接口

public interface EventStream {
    @Input("inEvent")
    SubscribableChannel inEvent();
    @Output("outEvent")
    MessageChannel outEvent();
}

我的控制台日志--

：在3.233秒内启动ConsumerApplication（JVM运行于4.004）：[使用者Clientid=Consumer-3,Groupid=Anonymous.0D0C87D6-EF39-4BFE-B475-4491C40CAF6D]发现组协调器Singh:9092(ID:2147483647 RACK:null):[使用者Clientid=Consumer-3,Groupid=Anonymous.0D0C87D6-EF39-4BFE-B475-4491C40CAF6D]撤消以前分配的分区[]:撤消的分区:[]:[使用者Clientid=Consumer-3,Groupid=Anonymous.[使用者Clientid=Consumer-3,Groupid=Anonymous.0D0C87D6-EF39-4BFE-B475-4491C40CAF6D]成功加入具有第1代的组：[使用者Clientid=Consumer-3,Groupid=Anonymous.0D0C87D6-EF39-4BFE-B475-4491C40CAF6D]设置新分配的分区[inEvent-0]:[使用者Client=Consumer-3,Groupid=Anonymous.0D0C87D6-EF39-4BFE-B475-4491C40CAF6D]将分区inEvent-0的偏移量重置为：分配的分区:[inEvent-0]

Answer 1

group属性不能在Kafka树中。必须是这样的：

我的使用者绑定到匿名使用者组，而不是我指定的使用者组。

spring:
  cloud:
    stream:
       bindings:
          inEvent:
            group: eventin
            destination: event

请参阅文档中的更多信息:http://cloud.spring.io/spring-cloud-static/spring-cloud-stream/2.1.1.release/single/spring-cloud-stream.html#consumer-groups

组是一个公共属性，因此它与绑定器实现无关。Kafka是针对Apache Kafka特定的属性，在绑定器实现级别上公开。