У меня есть два потребителя кафки, определенные в двух микро-сервисах от одного производителя с определенным идентификатором группы. Один из микро-сервисов не использует сообщение от производителя
@Component
@ConditionalOnProperty(value = "XXX", havingValue = "true")
public class EventListener {
@KafkaListener(id = "XX", topics = "#{'${topic'}")
public void consumeMessageEvent(Event messageEvent, ConsumerRecord<String, ?> record) {
}
}