kafka单节点部署无法访问问题解决

场景：在笔记本安装了一台虚拟机，在本地的虚拟机上部署了一个kafka服务：

写了一个测试程序，在笔记本上运行测试程序，访问虚拟机上的kafka，报如下异常：

2015-01-15 09:33:26 [kafka.producer.async.DefaultEventHandler]-[INFO] Back off for 100 ms before retrying send. Remaining retries = 1

2015-01-15 09:33:26 [kafka.client.ClientUtils$]-[INFO] Fetching metadata from broker id:0,host:192.168.108.136,port:9092 with correlation id 9 for 1 topic(s) Set(client-all-log-test)

2015-01-15 09:33:26 [kafka.producer.SyncProducer]-[INFO] Connected to 192.168.108.136:9092 for producing

2015-01-15 09:33:26 [kafka.producer.SyncProducer]-[INFO] Disconnecting from 192.168.108.136:9092

2015-01-15 09:33:47 [kafka.producer.SyncProducer]-[ERROR] Producer connection to ubuntu-machine:9092 unsuccessful

java.net.ConnectException : Connection timed out: connect

at sun.nio.ch.Net.connect0( Native Method)

at sun.nio.ch.Net.connect(Unknown Source)

at sun.nio.ch.SocketChannelImpl.connect(Unknown Source)

at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)

at kafka.producer.SyncProducer.connect(SyncProducer.scala:141)

at kafka.producer.SyncProducer.getOrMakeConnection(SyncProducer.scala:156)

at kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:68)

at kafka.producer.SyncProducer$$anonfun$send$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SyncProducer.scala:102)

at kafka.producer.SyncProducer$$anonfun$send$1$$anonfun$apply$mcV$sp$1.apply(SyncProducer.scala:102)

at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)

at kafka.producer.SyncProducer$$anonfun$send$1.apply$mcV$sp(SyncProducer.scala:101)

at kafka.producer.SyncProducer$$anonfun$send$1.apply(SyncProducer.scala:101)

at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)

at kafka.producer.SyncProducer.send(SyncProducer.scala:100)

at kafka.producer.async.DefaultEventHandler.kafka$producer$async$DefaultEventHandler$$send(DefaultEventHandler.scala:255)

at kafka.producer.async.DefaultEventHandler$$anonfun$dispatchSerializedData$2.apply(DefaultEventHandler.scala:106)

at kafka.producer.async.DefaultEventHandler$$anonfun$dispatchSerializedData$2.apply(DefaultEventHandler.scala:100)

at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)

at scala.collection.Iterator$class.foreach(Iterator.scala:772)

at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157)

at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190)

at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45)

at scala.collection.mutable.HashMap.foreach(HashMap.scala:95)

at kafka.producer.async.DefaultEventHandler.dispatchSerializedData(DefaultEventHandler.scala:100)

at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:72)

at kafka.producer.Producer.send(Producer.scala:76)

at kafka.javaapi.producer.Producer.send(Producer.scala:33)

at me.learn.kafka.demo.TestProducer.main( TestProducer.java:38)

Exception in thread "main" kafka.common.FailedToSendMessageException : Failed to send messages after 3 tries.

at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:90)

at kafka.producer.Producer.send(Producer.scala:76)

at kafka.javaapi.producer.Producer.send(Producer.scala:33)

at me.learn.kafka.demo.TestProducer.main( TestProducer.java:38)

原因应该网络问题，但是检查了防火墙设置，没有限制，将程序部署的虚拟机所在的服务器上，就可以运行了，说明还是网络的限制。

需要改动config文件夹下的server.properties中的以下两个属性

zookeeper.connect=localhost:2181 #改成zookeeper.connect=10.0.30.221:2181
#去掉host.name的注释
#host.name=localhost改成host.name=10.0.30.221

转载于:https://www.cnblogs.com/honeybee/p/5258853.html

kafka单节点部署无法访问问题解决相关推荐

Ubuntu下用devstack单节点部署Openstack
一.实验环境本实验是在Vmware Workstation下创建的单台Ubuntu服务器版系统中,利用devstack部署的Openstack Pike版. 宿主机:win10 1803 8G内存 ...
k8s二进制单节点部署
k8s二进制单节点部署常见的k8s部署方式 Kubernetes二进制部署(单节点) 环境准备部署etcd集群(这里就不在单独的服务器上部署,直接部署在各节点上,节省资源) 下载证书制作工具利用 ...
啃K8s之快速入门，以及哭吧S（k8s）单节点部署
啃K8s之快速入门,以及哭吧S(k8s)单节点部署一:Kubernets概述 1.1:Kubernets是什么? 1.2:Kubernets特性 1.3:Kubernets群集架构与组件 1.3.1 ...
Elasticsearch在Linux中的单节点部署和集群部署
目录一.Elasticsearch简介二.Linux单节点部署 1.软件下载解压 2.创建用户 3.修改配置文件 4.切换到刚刚创建的用户启动软件 5.测试三.Linux集群配置 1.拷贝文件 ...
kafka单节点创建 topic 超时
kafka单节点创建 topic 超时单节点kafka创建topic时报错:Timed out waiting for a node assignment. Call: createTopics 经 ...
skywalking单节点部署
skywalking单节点部署 skywalking服务部署下载skywalking服务文件下载地址:http://skywalking.apache.org/downloads/ 我使用的是Bi ...
openstack 系列: 基于CentOS7系统使用packstack工具单节点部署openstacktrain---Part-I安装简易命令
1说明本人非linux专业人士,更不是云计算专家部署过程是从各大博客自己百度知道各种搜索排查,硬是搭起了train环境过程纠结,先是在win 10 vmware 上安装centos7 再基于c ...
Graylog 日志服务器单节点部署
资料 https://docs.graylog.org/docs/ 简介 Graylog项目由Lennart Koopmann在2009年左右启动.当时,最着名的日志管理软件vendor发布了他们产品 ...
ElasticSearch学习(四)——Linux 单节点部署
文章名称地址 ElasticSearch学习(一)--概述前往 ElasticSearch学习(二)--索引.文档简单操作前往 ElasticSearch学习(三)--Windows 集群部署 ...

kafka单节点部署无法访问问题解决

kafka单节点部署无法访问问题解决相关推荐

最新文章

热门文章