Собственная Kafka

На этом этапе вы замените жёстко заданный идентификатор корреляции настоящим идентификатором из запроса.

Структура сообщения Kafka

Напомним формат сообщений запросов и ответов Kafka:

1. message_size: размер заголовка и тела.
2. Заголовок: метаданные запроса.
3. Тело: сами данные запроса.

На предыдущем этапе вы отправляли ответ с фиксированным correlation_id. Теперь вы извлечёте настоящий correlation_id из заголовка входящего запроса и вернёте его в ответе.

Разбор заголовка запроса

Чтобы извлечь correlation_id, нужно разобрать заголовок запроса. На этом этапе используется заголовок запроса v2.

Его структура:

Подробнее о типах данных см. Примитивные типы протокола.

Чтобы получить поле correlation_id, нужно определить его смещение в сообщении запроса. Пример запроса с расположением полей:

00 00 00 23  // message_size:        35
00 12        // request_api_key:     18
00 04        // request_api_version: 4
6f 7f c6 61  // correlation_id:      1870644833
...

Структура ответа остаётся такой же, как на предыдущем этапе:

00 00 00 00  // message_size:   0 (any value works for this stage)
6f 7f c6 61  // correlation_id: 1870644833 (extracted from request)

Тесты

Тестирующая система запустит вашу программу следующим образом:

$ ./your_program.sh

Затем подключится к брокеру на порту 9092 и отправит запрос с заголовком запроса v2:

$ echo -n "00000023001200046f7fc66100096b61666b612d636c69000a6b61666b612d636c6904302e3100" | xxd -r -p | nc localhost 9092 | hexdump -C

Брокер должен извлечь идентификатор корреляции из запроса и вернуть его в ответе:

00 00 00 00  // message_size:   0 (any value works for this stage)
6f 7f c6 61  // correlation_id: 1870644833

Примечания

• Пока не нужно разбираться, что именно запрашивает клиент. Вы займётесь этим позже.
• На этом этапе тестирующая система проверяет только длину поля message_size — 4 байта, но не его значение. Правильные значения message_size вы реализуете позже.
• Версии заголовков запроса и ответа независимы и не обязаны совпадать.