Синхронный Запрос-Ответ с использованием Apache Kafka

[ultar]

Не очень понятно какая из сторон отвечает за то, чтобы в топике было нужное количество партиций для потребителей? Что делать ответчику, если нужно отправить сообщение в partition_id, но партиции с таким номером нет.