kafka 跑起来 步骤
首先 刚进来的时候 测试Java的环境是否 正常运行
输入 Java -version
如果 正常就进行下一步
进入系统权限
输入 sudo -i 回车然后 $变为#即为成功 然后下一步
进入 你kafka解压的目录 不需要 进入bin目录
输入 bin/zookeeper-server-start.sh config/zookeeper.properties 运行成功会输出大量 没error 日志
新开一个窗口
重复获取系统权限那一步
进入 kafka的解压目录 进入bin目录
输入 ./kafka-server-start.sh ../config/server.properties 回车运行成功会输出大量无error日志
创建 topic
重复获取系统权限那一步
进入 kafka的解压目录 不需要进入bin目录
输入 bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
运行 成功 输出 Created topic "test"
查看 刚才创建的 topic
输入 bin/kafka-topics.sh --list --zookeeper localhost:2181
运行 成功 输出 test
发送消息
输入 bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
运行 出现 > 后面可以输入字符为正确
创建 消费者
重复获取系统权限那一步
进入 kafka的解压目录 不需要进入bin目录
输入 进入 kafka的解压目录 不需要进入bin目录
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
下面无光标 为正常
在 创建了 topic的页面
输入字符位置 输入字符 回车然后在消费者页面可以看到 topic输出的字符 即为成功