Group property not work in spring stream cloud?

Question

I used Spring Stream Cloud to consume messages on Kafka. When message produced on kafka all consumers hit.

but documentation of kafka says that by use of group only one consumer consume message.

this is my Consumer code.

@EnableBinding(Sink.class)

public class Consumer2 {


    @StreamListener(target = Sink.INPUT)
    public void consume(String message) {
        System.out.println("33333");

    }

    @StreamListener(target = Sink.INPUT)
    public void consume1(String message) {
        System.out.println("444444");

    }


}
}

and this is my config but both of my methods called :(

spring:
  cloud:
    stream:
      default-binder: kafka
      kafka:
        binder:
          brokers:
            - localhost:9092
      bindings:
        input:
          binder: kafka
          destination: abbas
          content-type: text/plain
          group: input-group-1

        output:
          binder: kafka
          destination: abbas
          group: output-group-1
          content-type: text/plain

Javier Gonzalez Benito Javier Gonzalez Benito · Accepted Answer · 2019-12-25T16:39:18

With that configuration, you only have 1 consumer (SINK.INPUT), not 2 consumers (@StreamListener is not a consumer, its a model for handling inbound messages)

That's why spring routes the inbound messages to your two @StreamListener annotates with the same sink.

Group property not work in spring stream cloud?

2 Answers