Sobes.tech
Senior

Mely Kafka-atribútumokat lehet írni küldéskor, és melyek csak olvashatók?

sobes.tech MI

Válasz az MI-től

В Kafka при отправке сообщения (продюсером) можно указать следующие реквизиты:

  • Ключ сообщения (key): используется для определения партиции.
  • Значение сообщения (value): основное содержимое.
  • Топик (topic): куда отправлять сообщение.
  • Заголовки (headers): дополнительные метаданные.
  • Timestamp: время создания сообщения (можно задать вручную или использовать системное время).

Реквизиты, доступные только на чтении при потреблении (консюмером):

  • Offset: уникальный номер сообщения в партиции.
  • Partition: номер партиции, из которой прочитано сообщение.
  • Timestamp: время записи сообщения в брокер (если не задано продюсером).

Таким образом, при отправке вы задаёте ключ, значение, заголовки, топик и timestamp. При чтении доступны эти же данные, а также offset и partition, которые нельзя изменить.