PHP RdKafka - установить количество партиций

Всем привет, изучаю сейчас php-клиент rdkafka.

Обратил внимание, что если при отправке сообщений в партиции передаю константу RD_KAFKA_PARTITION_UA, то процесс отрабатывает нормально, и сообщение появляется в очереди.

Как только пытаюсь передать другое число - сообщение не добавляется.

Возможно, это связано с настройкой количества партиций в топике, но какой параметр за это отвечает?

Пробовал использовать num.partitions, возвращается ошибка

Fatal error: Uncaught RdKafka\Exception: No such configuration property: "num.partitions"

Если у кого-то был опыт решения данной проблемы, поделитесь.

Заранее спасибо.


Ответы (0 шт):