spring.kafka.consumer.group-id: my-group
На проде несколько подов приложения. Если приходит сообщение, то только один из подов его слушает и обрабатывает.
Но есть “технический” кафка-топик, который должны слушать все поды. Для этого у одной из ConcurrentKafkaListenerContainerFactory<Object, Object> myKafkaListenerContainerFactory, отвечающий за этот технический топик, надо убрать group-id или задать для каждого пода уникальный идентификатор.
Как это сделать красиво?
Переопредили environment variable SPRING_KAFKA_CONSUMER_GROUP-ID
Обсуждают сегодня