client.id? или какой то есть внутренний идентификатор?
По клиент ид, если не задавать драйвер сам генерит, а дальше 1 партиция = 1 клиент ( в рамках группы)
вот меня смущает что у нас в коде используется спринговый @KafkaListener с одинаковым id для двух приложений. но странно что до этого не стреляло
Обсуждают сегодня