如何为 confluent-kafka 使用不同的端口？
How to use a different port for confluent-kafka?
我有一个 Kafka 运行 端口不同于默认的 9092。
如何让 confluent-kafka 使用那个端口？因为在 API documentation nor Github 中我都没有看到 "port" 配置，只有 bootstrap 服务器配置，它只是定义 Kafka 端点的 IP。
bootstrap 服务器参数不只定义 IP。它是定义为 : 的 Kafka 端点列表，以逗号分隔。因此，例如，在您的情况下，如果您在非标准端口（即 9093）和本地主机上安装了 Kafka，则 bootstrap 服务器参数可以是 localhost:9093.
你可以看到这个https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md
它说 bootstrap.servers 是 metadata.broker.list
的别名
metadata.broker.list 描述是：
Initial list of brokers as a CSV list of broker host or host:port. The application may also use rd_kafka_brokers_add() to add brokers during runtime.
Type: string
实际上你可以使用这个
{'bootstrap.server' : 'ip:your_host,...',
....
}
作为生产者或消费者启动的 Kwargs。
我有一个 Kafka 运行 端口不同于默认的 9092。
如何让 confluent-kafka 使用那个端口？因为在 API documentation nor Github 中我都没有看到 "port" 配置，只有 bootstrap 服务器配置，它只是定义 Kafka 端点的 IP。
bootstrap 服务器参数不只定义 IP。它是定义为 : 的 Kafka 端点列表，以逗号分隔。因此，例如，在您的情况下，如果您在非标准端口（即 9093）和本地主机上安装了 Kafka，则 bootstrap 服务器参数可以是 localhost:9093.
你可以看到这个https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md
它说 bootstrap.servers 是 metadata.broker.list
的别名metadata.broker.list 描述是：
Initial list of brokers as a CSV list of broker host or host:port. The application may also use rd_kafka_brokers_add() to add brokers during runtime. Type: string
实际上你可以使用这个
{'bootstrap.server' : 'ip:your_host,...',
....
}
作为生产者或消费者启动的 Kwargs。