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
3. 安全性提升：此版本引入了对SASL（Simple Authentication and Security Layer）和SSL的支持，增强了Kafka集群的安全性，保护了数据传输过程中的隐私。 4. 更强大的消费者API：Kafka 0.10.x系列引入了新的消费者...
赠送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. 生产与消费消息：使用示例程序或...
5. 接着启动Kafka服务，运行`kafka-server-start.bat ../config/server.properties`。 创建和操作主题： 6. 创建一个新主题，如`test-topic`，运行`kafka-topics.bat --create --topic test-topic --partitions 3 -...
在开始安装前，确保你的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-...
在压缩包子文件的文件名称列表中只看到“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 ...