刚开始启动kafka时有警告,没有在意,但是在使用kafkaManager创建的页面操作时出现少了一台机器。
创建生产者和消费者时出现了错误。最后发现有问题。
1.kafka安装好之后,在安装kafkaManager管理包,这个可以使用页面操作kafka
2.再次需要启动的进程有
namenode, datanode,yarn,zookeeper 历史服务器,kafka
kafka依赖zookeeper,所以zookeeper先启动。
3.执行 ./bin/kafka-manager启动kafka客户端,如图所示
- 定义集群名称
- 确定要连接的zookeeper集群的主机名
- 。。。下面的操作就不介绍了。有点跑题了。
出现java.net.NoRouteToHostException: 没有到主机的路由
原因:
1. 可能时主机ip和主机名没有映射 vim /etc/hosts ->查看映射关系 2. 可能是防火墙没有关闭 查看防火墙状态:firewall-cmd --state 关闭防火墙:systemctl stop firewalld.service 注意:上面是centos7的系统命令,如果是centos6系统,则相关命令不一样,可自行查询
经过检查发现是由于防火墙没有全部关闭。
关闭后启动成功。



