kafka 在linux ubuntu下跑起来攻略(不包含解压之类的)

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输出的字符 即为成功

猜你喜欢

转载自blog.csdn.net/robotShuiMo/article/details/82963099