Сообщения записываются последовательно в файлы сегментов (segments) в логе. При записи каждого сообщения Kafka добавляет его в конец текущего активного сегмента. Каждый сегмент имеет фиксированный или настраиваемый размер, при достижении которого Kafka создает новый сегмент. Офсет (offset) сообщения является уникальным идентификатором в рамках раздела (partition) и представляет его позицию в этом логе.
Передача сообщений основана на механизме pull: потребители (consumers) самостоятельно запрашивают данные у брокеров (brokers). Каждый потребитель группы хранит свой офсет для каждого раздела, отслеживая, до какого сообщения он прочитал дан
Сообщения записываются последовательно в файлы сегментов (segments) в логе. При записи каждого сообщения Kafka добавляет его в конец текущего активного сегмента. Каждый сегмент имеет фиксированный или настраиваемый размер, при достижении которого Kafka создает новый сегмент. Офсет (offset) сообщения является уникальным идентификатором в рамках раздела (partition) и представляет его позицию в этом логе.
Передача сообщений основана на механизме pull: потребители (consumers) самостоятельно запрашивают данные у брокеров (brokers). Каждый потребитель группы хранит свой офсет для каждого раздела, отслеживая, до какого сообщения он прочитал дан
Register or sign in to get access to full answers for all questions from the question bank.