kafka运行过程中出现了java.net.UnknownHostException: localhost.localdomain: localhost.localdomain: 未知的名称或服务
[2016-01-17 23:17:52,291] ERROR Unknown error when running consumer: (kafka.tools.ConsoleConsumer$)
java.net.UnknownHostException: localhost.localdomain: localhost.localdomain: 未知的名称或服务
at java.net.InetAddress.getLocalHost(InetAddress.java:1475)
at kafka.consumer.ZookeeperConsumerConnector.<init>(ZookeeperConsumerConnector.scala:122)
at kafka.consumer.ZookeeperConsumerConnector.<init>(ZookeeperConsumerConnector.scala:146)
at kafka.consumer.Consumer$.create(ConsumerConnector.scala:109)
at kafka.consumer.OldConsumer.<init>(BaseConsumer.scala:73)
at kafka.tools.ConsoleConsumer$.run(ConsoleConsumer.scala:63)
at kafka.tools.ConsoleConsumer$.main(ConsoleConsumer.scala:47)
at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala)
Caused by: java.net.UnknownHostException: localhost.localdomain: 未知的名称或服务
at java.net.Inet6AddressImpl.lookupAllHostAddr(Native Method)
at java.net.InetAddress$1.lookupAllHostAddr(InetAddress.java:901)
at java.net.InetAddress.getAddressesFromNameService(InetAddress.java:1295)
at java.net.InetAddress.getLocalHost(InetAddress.java:1471)
... 7 more
编辑server.properties
host.name=localhost 改为ip地址
192.168.60.193 localhost.localdomain localhost
相关推荐
mvn install:install-file -DgroupId=io.confluent -DartifactId=kafka-schema-registry-client -Dversion=6.2.2 -Dfile=/root/kafka-schema-registry-client-6.2.2.jar -Dpackaging=jar 官网下载地址 packages....
赠送jar包:kafka-clients-0.10.0.1.jar; 赠送原API文档:kafka-clients-0.10.0.1-javadoc.jar; 赠送源代码:kafka-clients-0.10.0.1-sources.jar; 赠送Maven依赖信息文件:kafka-clients-0.10.0.1.pom; 包含...
java.lang.RuntimeException: java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.RecordTooLargeException: The request included a message larger than the max message size the server ...
《深入理解Kafka:从kafka_2.13-2.8.1.tgz解压文件探索》 Apache Kafka是一款高性能、分布式的消息中间件,它最初由LinkedIn开发,后来成为Apache软件基金会的顶级项目。Kafka的核心特性包括高吞吐量、持久化、分区...
赠送jar包:kafka_2.11-0.10.0.1.jar; 赠送原API文档:kafka_2.11-0.10.0.1-javadoc.jar; 赠送源代码:kafka_2.11-0.10.0.1-sources.jar; 赠送Maven依赖信息文件:kafka_2.11-0.10.0.1.pom; 包含翻译后的API文档...
3. 实时分析:结合Spark或Flink等流处理引擎,对Kafka中的数据进行实时计算和分析。 4. 消息队列:作为企业内部的消息传输平台,实现系统间的异步通信和解耦。 总结,`kafka_2.10-0.8.2.1.tgz`是Kafka的一个关键...
5. 启动服务:使用`bin/kafka-server-start.sh config/server.properties`启动Kafka服务器。 6. 创建主题:使用`bin/kafka-topics.sh`创建主题,例如 `bin/kafka-topics.sh --create --zookeeper localhost:2181 --...
下载后直接 unzip kafka-manager-1.3.3.7.zip -d /data/ ...#kafka-manager.zkhosts="localhost:2181" ##注释这一行,下面添加一行 kafka-manager.zkhosts="10.1.0.50:1211,10.1.0.60:1211,10.1.0.70:1211
赠送jar包:kafka-clients-0.9.0.0.jar; 赠送原API文档:kafka-clients-0.9.0.0-javadoc.jar; 赠送源代码:kafka-clients-0.9.0.0-sources.jar; 赠送Maven依赖信息文件:kafka-clients-0.9.0.0.pom; 包含翻译后...
【标题与描述解析】 标题"最新版linux kafka_2.12-2.5.0.tgz"提及的是一个适用于Linux操作系统的Kafka软件包,版本号为2.5.0,且是针对...这个压缩包文件很可能是为了在Linux环境中安装和运行Kafka服务器的必要组件。
已编译 Kafka-Manager-1.3.3.22 linux下直接解压解压kafka-manager-1.3.3.22.zip到/opt/module目录 ...备注:指定端口号看启动过程中 "-Dhttp.port=7456" 端口可以自己设置 http://hadoop102:7456
3. 启动ZooKeeper:在Kafka目录下运行ZooKeeper服务器。 4. 启动Kafka:配置`server.properties`,然后启动Kafka服务。 5. 创建主题:使用`bin/kafka-topics.sh`脚本创建主题。 6. 生产与消费消息:使用示例程序或...
在开始安装前,确保你的Linux系统已经安装了Java Development Kit (JDK) 8或以上版本,因为Kafka运行需要Java环境。你可以通过命令`java -version`来检查是否已安装以及版本信息。 二、下载与解压 你已经拥有了名为...
5. **启动Kafka**:运行bin目录下的kafka-server-start.sh脚本启动Kafka服务。 6. **创建主题**:使用kafka-topics.sh工具创建主题,指定主题名、分区数和副本数。 7. **生产与消费消息**:使用kafka-console-...
5. 接着启动Kafka服务,运行`kafka-server-start.bat ../config/server.properties`。 创建和操作主题: 6. 创建一个新主题,如`test-topic`,运行`kafka-topics.bat --create --topic test-topic --partitions 3 -...
在压缩包子文件的文件名称列表中只看到“kafka”,这可能是解压后的目录名称,包含了安装或运行Kafka所需的所有文件和配置。通常,这些文件会包括服务器配置文件(server.properties)、日志配置(log4j.properties...
依赖方式 <groupId>org.apache.kafka <artifactId>kafka_2.10 <version>0.10.0.0 但是没有被中央仓库的任何jar包依赖!您可以在这里点击下载
3. 配置:编辑`conf/application.conf`文件,设置你的Kafka集群信息,如`kafka.cluster.zk.list`。 4. 启动:运行启动脚本,如`./bin/kafka-manager`,Kafka Manager服务将开始监听指定端口。 在实际使用中,你还...
- `bin`目录:包含了启动和管理Kafka服务的脚本,如`kafka-server-start.sh`、`kafka-console-producer.sh`和`kafka-console-consumer.sh`。 - `config`目录:包含默认配置文件,如`server.properties`(配置Kafka ...
1. Java运行环境:Kafka需要Java 8或更高版本,因此请确保已安装JDK。 2. 操作系统:Kafka在大多数Linux发行版上都能运行,本文以Ubuntu为例进行说明。 三、下载与解压 从Apache Kafka官方网站下载对应版本的二...