Что означают значения Position под apache kafka partiton log? - PullRequest
0 голосов
/ 09 ноября 2018

Что означают значения позиции под файлом журнала ниже?

Starting offset: 0
offset: 0 position: 0 CreateTime: 1541783974960 isvalid: true keysize: -1 valuesize: 10 magic: 2 compresscodec: NONE producerId: -1 producerEpoch: -1 sequence: -1 isTransactional: false headerKeys: [] payload: Spam_Mail1
offset: 1 position: 78 CreateTime: 1541784566896 isvalid: true keysize: -1 valuesize: 0 magic: 2 compresscodec: NONE producerId: -1 producerEpoch: -1 sequence: -1 isTransactional: false headerKeys: [] payload: 
offset: 2 position: 146 CreateTime: 1541784725893 isvalid: true keysize: -1 valuesize: 0 magic: 2 compresscodec: NONE producerId: -1 producerEpoch: -1 sequence: -1 isTransactional: false headerKeys: [] payload:

1 Ответ

0 голосов
/ 11 ноября 2018

Атрибут позиции представляет физическую позицию сообщения в файле журнала сегмента.

Этот же атрибут также доступен в файле индекса позиции вместе со смещением.

Когда потребитель отправляет запрос на выборку для сообщения со смещением x , брокеры ищут смещение, наиболее близкое к смещению x в индексном файле, получают значение позиции из этого индексный файл и идет к этой позиции в файле журнала (той, на которую вы ссылаетесь в своем вопросе), чтобы получить сообщение.

Надеюсь, это поможет!

...