ITPub博客

首页 > Linux操作系统 > Linux操作系统 > 安装测试kafka

安装测试kafka

原创 Linux操作系统 作者:zchbaby2000 时间:2020-03-28 19:30:06 0 删除 编辑


在server1和server2上安装kafka
cd /tmp
tar -xzf kafka_2.12-2.4.1.tgz
mv kafka_2.12-2.4.1 kafka
cd kafka

在server1启动ZooKeeper
./bin/zookeeper-server-start.sh ./config/zookeeper.properties &

在server1启动kafka
./bin/kafka-server-start.sh ./config/server.properties &

查看zookeeper和kafka服务是否已经启动
ps -ef | grep kafka

创建一个叫"test"的topic,它只有一个分区,一个副本:
./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

可以用list查看创建的topic,当前创建了1个topic
./bin/kafka-topics.sh --list --zookeeper localhost:2181
test

在 server1 上打开一个终端发送消息。运行producer并在控制台中输一些消息,这些消息将被发送到服务端
./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

打开另一个终端开启consumer,可以读取到刚才发出的消息并输出
./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

在server2上发送消息。运行producer并在控制台中输一些消息,这些消息将被发送到服务端
/tmp/kafka/bin/kafka-console-producer.sh --broker-list server1:9092 --topic test

在server1上打开另一个终端开启consumer,可以读取到刚才发出的消息并输出。
/tmp/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

来自 “ ITPUB博客 ” ,链接:http://blog.itpub.net/725820/viewspace-2683138/,如需转载,请注明出处,否则将追究法律责任。

上一篇: RDBMS VS XML VS NoSQL
全部评论
混迹IT 15年,喜欢Java开发,喜欢Python,还喜欢数据库的开发,架构设计,运维和性能优化
  • 博文量
    235
  • 访问量
    78593