SpringKafka Consumer @KafkaListener Anotasyonu groupId Alanı - Consumer Group

Giriş

Consumer Group ismini belirtir

Örnek

Şöyle yaparız. Burada farklı consumer group oluşturularak aynı mesajın iki farklı listener'a gitmesi sağlanıyor

//THE CODE READY TO COPY, LAUNCH AND TEST
@Service
public class KafkaScheduler {

    @Autowired
    private  KafkaTemplate<String, String> kafkaTemplate;

    @Scheduled(cron = "*/10 * * * * *")
    public void send() {
        kafkaTemplate.send("topic-one", "kafkaMessage " + new Date());
        System.out.println("MESSAGE WAS SENT");
    }

    @KafkaListener(id = "id1",
            groupId = "group-one",
            topics = "topic-one")
    public void listenServiceCall(@Payload String message) {
        System.out.println("GROUP ONE MESSAGE " + message);
    }

    @KafkaListener(id = "id2",
            groupId = "group-two",
            topics = "topic-one")
    public void listenServiceCall2(@Payload String message) {
        System.out.println("GROUP TWO MESSAGE " + message);
    }
}