Не удается настроить группу потребителей в Кафке с Python

По умолчанию потребитель начинает потреблять с последнего зафиксированного смещения, которое, вероятно, является последним смещением в вашем случае.

auto.offset.reset применяется только тогда, когда нет зафиксированных смещений. Поскольку по умолчанию потребитель автоматически фиксирует смещения, он обычно применяется только при первом запуске (есть несколько других случаев, но они не имеют значения в этом примере).

Таким образом, чтобы видеть поток сообщений, вам нужно либо начать производить, когда ваш потребитель работает, либо использовать другое имя группы, чтобы разрешить применение auto.offset.reset.