Kafka-дан керектүү маалыматтарды, анын ичинде негизги мазмуну болбосо, керектүү маалыматтарды окуй алат?

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

• Ключ сообщения (key) — используется для определения партиции и логики маршрутизации.
• Топик (topic) — имя топика, из которого прочитано сообщение.
• Партиция (partition) — номер партиции внутри топика.
• Оффсет (offset) — позиция сообщения в партиции, уникальный идентификатор для чтения.
• Временная метка (timestamp) — время создания или логирования сообщения.
• Заголовки (headers) — произвольные пары ключ-значение, которые можно использовать для передачи дополнительной информации.

Пример получения этих реквизитов в Java:

ConsumerRecord<String, String> record = ...; // полученное сообщение
String key = record.key();
String value = record.value();
String topic = record.topic();
int partition = record.partition();
long offset = record.offset();
long timestamp = record.timestamp();
Headers headers = record.headers();