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

На этом этапе вы реализуете ответ Fetch для неизвестного топика.

🚧 Мы ещё готовим инструкции для этого этапа. Ниже приведено описание работы тестирующей системы.

Пока вы можете задать вопросы на форуме по этой ссылке.

Тесты

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

$ ./your_program.sh

Затем подключится к серверу на порту 9092 и отправит запрос Fetch (v16). Он содержит один топик с неизвестным идентификатором, то есть топик ещё не существует.

Она проверит, что:

• Первые 4 байта ответа («длина сообщения») корректны.
• Идентификатор корреляции в заголовке ответа совпадает с идентификатором в заголовке запроса.
• Код ошибки в теле ответа равен 0 (нет ошибки).
• Поле throttle_time_ms ответа равно 0.
• Поле responses ответа содержит 1 элемент, в котором:
  • Поле topic_id совпадает со значением из запроса.
  • Массив partitions содержит 1 элемент, в котором:
    • Поле partition_index равно 0.
    • Поле error_code равно 100 (UNKNOWN_TOPIC_ID).

Примечания

• На этом этапе нужно разобрать запрос Fetch, чтобы получить topic_id для ответа.
• Официальная документация запроса Fetch находится здесь. Прокрутите до раздела «Fetch Response (Version: 16)».