标签：火墙 l命令 ip地址 beginning soft 窗口 for tor 发送
安装前的准备工作（zk已经部署完毕）
关闭防火墙
service iptables stop #临时关闭 chkconfig iptables off && setenforce 0 #永久关闭
java -version ? java version "1.8.0_171" ? Java(TM) SE Runtime Environment (build 1.8.0_171-b11) ? Java HotSpot(TM) 64-Bit Server VM (build 25.171-b11, mixed mode)
如果没有安装，请先安装java环境 参考JDK安装方法 ?/ .bashrc文件(环境变量配置文件方式二)
2.上传kafka文件到虚拟机中kafka_2.12-2.2.0
rz 命令调出上传窗口
ll命令查看上传的kafka文件
3.解压安装kafka到/opt中
tar -zxvf kafka_2.11-1.0.0.tgz -C /opt/ 重命名kafka的文件 ： mv kafka_2.11-1.0.0 /opt/kafka
4.切换到kafka的配置文件目录
pwd
cd /opt/kafka/config
5.kafka安装目录下的config文件夹为其配置文件，我们需要修改的有 server.properties和zookeeper.properties。
mkdir kafka-logs-0 server.properties： kafka的配置文件 ? log.dirs=/tmp/kafka-logs ? 修改为: ? log.dirs=/opt/kafka/kafka-logs-0 host.name=你的ip地址 zookeeper.properties kafka自带的zookeeper的配置 ? dataDir=/tmp/zookeeper ? 修改为: ? dataDir=/opt/kafka/my_zookeeper
6.启动zookeeper
/opt/kafka/bin/zookeeper-server-start.sh /opt/kafka/config/zookeeper.properties
7.启动kafka
/opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties
8.创建主题 (让我们创建一个名为“test”的主题，它只包含一个分区，只有一个副本)
/opt/kafka/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic 1704D ? 备注： 或者，您可以将代理配置为在发布不存在的主题时自动创建主题，而不是手动创建主题。
9.查看主题: 如果我们运行list topic命令，我们现在可以看到该主题
/opt/kafka/bin/kafka-topics.sh --list --zookeeper localhost:2181
/opt/kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic 1704D ? >等待输入发送的消息
11.启动消费者
/opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server 192.168.25.133:9092 --topic 1704D --from-beginning 从第一条开始接受 /opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server 192.168.25.133:9092 --topic 1704D从现在生产者发送开始接受。
标签：火墙 l命令 ip地址 beginning soft 窗口 for tor 发送
原文地址：https://www.cnblogs.com/liujinqq7/p/12656447.html
