Я начинаю изучать Kafka для решения корпоративных задач.

Во время моих чтений у меня возникли вопросы:

Когда производитель создает сообщение - оно будет указыватьтема он хочет отправить сообщение, верно? Это заботится о перегородках?Когда подписчик работает - указывает ли он свой идентификатор группы, чтобы он мог быть частью группы потребителей той же темы или нескольких тем, которые интересуют эту группу потребителей?

У каждой группы потребителей есть соответствующий раздел на брокере или у каждого потребителя есть один?

Как перегородки, созданные брокером, поэтому не заботятся о потребителях?

Поскольку это очередь со смещением для каждого раздела, отвечает ли потребитель, какие сообщения он хочет прочитать? Нужно ли сохранять его состояние?

Что происходит, когда сообщение удаляется из очереди? - Например: удержание было в течение 3 часов, затем проходит время, как обрабатывается смещение с обеих сторон?