报错:Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
2023-09-11 14:14:33 时间
报错背景:
启动kafka消费者之后出现这种报错,持续打印相同信息。
报错现象:
[root@master kafka_2.11-1.1.1]# /opt/kafka/kafka_2.11-1.1.1/bin/kafka-console-consumer.sh --bootstrap-server master:9092 --topic alarmHis SLF4J: Class path contains multiple SLF4J bindings. SLF4J: Found binding in [jar:file:/bigdata/app/.jar!/org/slf4j/impl/StaticLoggerBinder.class] SLF4J: Found binding in [jar:file:/bigdata/app/bigdata-1.0-SNAPSHOT-jar-with-dependencies.jar!/org/slf4j/impl/StaticLoggerBinder.class] SLF4J: Found binding in [jar:file:/opt/kafka/kafka_2.11-1.1.1/libs/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory] [2019-05-23 08:35:56,555] WARN [Consumer clientId=consumer-1, groupId=console-consumer-68734] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2019-05-23 08:35:56,608] WARN [Consumer clientId=consumer-1, groupId=console-consumer-68734] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2019-05-23 08:35:56,709] WARN [Consumer clientId=consumer-1, groupId=console-consumer-68734] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2019-05-23 08:35:56,911] WARN [Consumer clientId=consumer-1, groupId=console-consumer-68734] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2019-05-23 08:35:57,364] WARN [Consumer clientId=consumer-1, groupId=console-consumer-68734] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
报错原因:
不明。
报错解决:
相关文章
- Python 操作 Kafka --- kafka-python
- 报错:Kafka No kafka server to stop
- 报错:Bootstrap broker basecoalmine:2181 (id: -1 rack: null) disconnected (org.apache.kafka.clients.NetworkClient)
- 《Apache Common CLI官方文档
- Apache Kafka监控之Kafka Web Console
- Apache-Flink深度解析-DataStream-Connectors之Kafka
- Kafka - kafka环境配置以及参数分析
- CentOS7:搭建SVN + Apache 服务器
- Apache Kafka学习 (一)
- CVE-2020-11996: Apache Tomcat HTTP/2 拒绝服务攻击漏洞通告
- CVE-2020-1948: Apache Dubbo 远程代码执行漏洞通告
- 【漏洞通告】Apache Kylin 远程命令执行漏洞(CVE-2020-1956)
- import org.apache.ibatis.annotations.Param 报错
- mac下的apache项目发布出现403
- Kafka集群管理工具kafka-manager的安装使用
- Apache Kafka KIP 介绍
- Benchmarking Apache Kafka, Apache Pulsar, and RabbitMQ: Which is the Fastest?
- Kafka实战:集群SSL加密认证和配置(最新版kafka-2.7.0)
- 如何使用JMeter测试Kafka:Apache Kafka - How to Load Test with JMeter
- kafka producer batch expired TimeoutException: KAFKA-5621、KIP-91(Provide Intuitive User Timeouts in The Producer)、KAFKA-5886
- Introducing KSQL: Streaming SQL for Apache Kafka
- Offset Management For Apache Kafka With Apache Spark Streaming
- How Cigna Tuned Its Spark Streaming App for Real-time Processing with Apache Kafka
- Flafka: Apache Flume Meets Apache Kafka for Event Processing
- Understanding, Operating and Monitoring Apache Kafka
- 大数据教程之Apache Kafka 入门
- 《深入理解Elasticsearch(原书第2版)》——第1章 Elasticsearch简介 1.1 Apache Lucene简介
- Tomcat启动报错org.apache.coyote.AbstractProtocol.init Failed to initialize end point associated with ProtocolHandler ["http-apr-8080"]”
- Windows下phpStudy中的Apache无法启动的排查方法
- 压力测试工具apache-ab讲解
- 【php】Apache无法自己主动跳转却显示文件夹与php无法连接mysql数据库的解决方式
- 如何使用 apache的POI读取日期格式数据
- apache-spark导入eclipse环境
- How to Configure Tomcat/JBoss and Apache HTTPD for Load Balancing and Failover
- java.io.FileNotFoundException: D:tomcat2apache-tomcat-5.5.26webappsROOTworkflatUpload (拒绝访问。)