Kafka: come fare in modo che un singolo messaggio di un topic venga letto da due servizi diversi?

Чтобы одно сообщение из Kafka топика прочитали два разных сервиса, нужно, чтобы эти сервисы были в разных группах потребителей (consumer groups). В Kafka сообщения доставляются каждому consumer group независимо, а внутри группы — каждому сообщению соответствует один потребитель.

Пример:

• Сервис A — consumer group "serviceA-group"
• Сервис B — consumer group "serviceB-group"

Оба сервиса подписываются на один и тот же топик, но так как они в разных группах, каждый получит все сообщения из топика.

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("group.id", "serviceA-group"); // или "serviceB-group" для второго сервиса
props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
consumer.subscribe(Collections.singletonList("your-topic"));
// далее обработка сообщений

Таким образом, каждый сервис получает копию всех сообщений из топика.