pykafka: 'Failed to connect newly created broker for ip:host'
kafka-python: 'NoBrokersAvailable'
目前是 broker 或者配置问题? 另外我服务器不需要安装 kafka 了吧?
我才看了半天 kafka 菜鸡 求教大佬们
后来加上api_version参数后就如下错误,找了好多说是kafka配置问题..
INFO:kafka.client:Bootstrap succeeded: found 1 brokers and 35 topics.
INFO:kafka.conn:<BrokerConnection node_id=bootstrap host=host:port <connected> [IPv4 ('host', port)]>: Closing connection.
DEBUG:kafka.conn:<BrokerConnection node_id=bootstrap host=host:port <disconnecting> [IPv4 ('host', port)]>: reconnect backoff 0.05978240071782098 after 1 failures
DEBUG:kafka.metrics.metrics:Added sensor with name bufferpool-wait-time
DEBUG:kafka.metrics.metrics:Added sensor with name batch-size
DEBUG:kafka.metrics.metrics:Added sensor with name compression-rate
DEBUG:kafka.metrics.metrics:Added sensor with name queue-time
DEBUG:kafka.metrics.metrics:Added sensor with name produce-throttle-time
DEBUG:kafka.metrics.metrics:Added sensor with name records-per-request
DEBUG:kafka.metrics.metrics:Added sensor with name bytes
DEBUG:kafka.metrics.metrics:Added sensor with name record-retries
DEBUG:kafka.metrics.metrics:Added sensor with name errors
DEBUG:kafka.metrics.metrics:Added sensor with name record-size-max
DEBUG:kafka.producer.sender:Starting Kafka producer I/O thread.
DEBUG:kafka.producer.kafka:Kafka producer started
DEBUG:kafka.producer.kafka:Requesting metadata update for topic enmonitor
DEBUG:kafka.client:Initializing connection to node 0 for metadata request
DEBUG:kafka.client:Initiating connection to node 0 at host_1:port
DEBUG:kafka.metrics.metrics:Added sensor with name node-0.bytes-sent
DEBUG:kafka.metrics.metrics:Added sensor with name node-0.bytes-received
DEBUG:kafka.metrics.metrics:Added sensor with name node-0.latency
1
nilai 2018-08-21 12:44:16 +08:00
advertised.listeners= 这个项有没有配置上??
|
2
yellowmarlboro OP @nilai 这个配置是在远程服务器 server.properties 配置的是吧.. 远程没配置好的问题么?
我指定了 api_version 更改了以后就有附言的问题,远程服务器人告诉我是 api 版本问题 可是我模块已经最高了啊并且官网支持现在 kafka 版本的。。 |
3
Pythonerxiaobai 2018-10-18 21:16:04 +08:00
@yellowmarlboro 楼主这个问题解决了么?我也遇到了相同的问题
|