Работает в FIFO - просто последовательный лог, пишем на диск в одном стриме (sequential write), читаем не удаляя сообщения (а перемещаем offset на каждую группу). Да, можно! Ты можешь явно указать, что консьюмер должен читать только из конкретной партиции топика, не участвуя в балансировке через Consumer Group. Пример на Java: consumer.assign(Arrays.asList(new TopicPartition("my-topic", 0))); Или в Go (с использованием segmentio/kafka-go, например): r := kafka...

Apache Kafka нынче используется большинством компаний. Нередко Кафку описывают словами "шина данных" - зачастую это главная артерия данных в больших и сложных системах, по которой циркулируют данные между различными ее частями. В этой статье и я расскажу, зачем и как появился этот инструмент, какие проблемы решает и почему он так важен. В серии статей "Узнай-ай-ти" я простыми словами объясняю явления, подходы и технологии из мира IT. Если Вы хотите о чем-то узнать, пишите в комментариях, и я обязательно разберу это в будущих статьях...