要先设置host, etc/hosts,添加
127.0.0.1 机器名
创建目录
修改日志保存位置
启动kafka
启动脚本 内容 启动脚本后面加&后台运行,如果不加centos 6.5一直显示启动,不能进入到窗口页面
#!/bin/bash
#chkconfig:2345 99 90
#description:kafka
#processname:kafka
kafka="/usr/soft/kafka_2.11-0.9.0.1/bin/kafka-server-start.sh"
config="/usr/soft/kafka_2.11-0.9.0.1/config/server.properties"
kafkastop="/usr/soft/kafka_2.11-0.9.0.1/bin/kafka-server-stop.sh"
case $1 in
start) $kafka $config;;
stop) $kafkastop;;
*) echo "require start|stop" ;;
esac
保存文件名为kafka
创建主题
生产者
打开配置文件
[root@localhost ~]# vi /etc/sysconfig/iptables
正确的配置文件
# Firewall configuration written by system-config-firewall
# Manual customization of this file is not recommended.
*filter
:INPUT ACCEPT [0:0]
:FORWARD ACCEPT [0:0]
:OUTPUT ACCEPT [0:0]
-A INPUT -m
state –state ESTABLISHED,RELATED -j ACCEPT
-A INPUT -p icmp -j ACCEPT
-A INPUT -i lo -j ACCEPT
-A INPUT -m
state –state NEW -m tcp -p tcp –dport 22 -j ACCEPT
-A INPUT -m
state –state NEW -m tcp -p tcp –dport 80 -j ACCEPT
-A INPUT -j REJECT –reject-with icmp-host-prohibited
-A FORWARD -j REJECT –reject-with icmp-host-prohibited
COMMIT
-A INPUT -m state –state NEW -m tcp -p tcp –dport * -j ACCEPT
注意点:新开放的端口一定要在端口22后面
重启防火墙使配置生效
[root@localhost ~]# /etc/init.d/iptables restart
其它
查看开放端口
[root@localhost ~]# /etc/init.d/iptables status