我有一个Kafka在一个不同于默认的9092端口运行。我怎么能告诉合流Kafka使用那个港口?因为在api文档和github中我都没有看到“端口”配置,只有bootstrap服务器配置,它只定义kafka端点的ip。
tjrkku2a1#
你可以看到这个https://github.com/edenhill/librdkafka/blob/master/configuration.md它说bootstrap.servers是metadata.broker.list的别名metadata.broker.list描述为:代理的初始列表作为代理主机或服务器的csv列表host:port. 应用程序还可以使用rd\u kafka\u brokers\u add()在运行时添加代理。类型:字符串实际上你可以用这个
{'bootstrap.server' : 'ip:your_host,...', .... }
作为生产者或消费者的启蒙运动。
6psbrbz92#
bootstrap server参数不仅仅定义ip。这是一个Kafka端点列表,定义为:用逗号分隔。因此,例如,如果您在非标准端口(即9093)和localhost上有kafka,那么bootstrap server参数可以是localhost:9093.
2条答案
按热度按时间tjrkku2a1#
你可以看到这个https://github.com/edenhill/librdkafka/blob/master/configuration.md
它说bootstrap.servers是metadata.broker.list的别名
metadata.broker.list描述为:
代理的初始列表作为代理主机或服务器的csv列表host:port. 应用程序还可以使用rd\u kafka\u brokers\u add()在运行时添加代理。类型:字符串
实际上你可以用这个
作为生产者或消费者的启蒙运动。
6psbrbz92#
bootstrap server参数不仅仅定义ip。这是一个Kafka端点列表,定义为:用逗号分隔。因此,例如,如果您在非标准端口(即9093)和localhost上有kafka,那么bootstrap server参数可以是localhost:9093.