У меня Kafka работает в порту, отличном от порта по умолчанию 9092.
Как я могу указать confluent-kafka на использование этого порта? Потому что ни в документации по API, ни в Github Я вижу конфигурацию "порта", только конфигурацию сервера начальной загрузки, которая предназначена только для определения IP конечной точки Kafka.
Параметр сервера начальной загрузки не определяет только IP. Это список конечных точек Kafka, определенных как: разделенных запятыми. Так, например, в вашем случае, если у вас есть Kafka на нестандартном порту, то есть 9093 и на localhost, параметр сервера начальной загрузки может быть localhost: 9093.
Вы могли увидеть это https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md
он говорит, что bootstrap.servers является псевдонимом для metadata.broker.list
А описание metadata.broker.list:
Первоначальный список брокеров в виде CSV-списка брокеров host или host: port. Приложение также может использовать rd_kafka_brokers_add () для добавления посредников во время выполнения. Тип: строка
На самом деле вы могли бы использовать это
{'bootstrap.server' : 'ip:your_host,...',
....
}
как Kwargs по инициативе производителя или потребителя.
