Ubuntu16.04 install kafka_2.10-0.10.2.1 And zookeeper-3.4.10

 zookeeper

  wget http://mirror.bit.edu.cn/apache/zookeeper/zookeeper-3.4.10/zookeeper-3.4.10.tar.gz

  tar zxvf kafka_2.10-0.10.2.1.tgz

  cp conf/zoo_sample.cfg conf/zoo.cfg

  sudo mv zookeeper-3.4.10 /opt/zookeeper/

  1.  bin/zkServer.sh start

kafka

  wget http://mirrors.tuna.tsinghua.edu.cn/apache/kafka/0.10.2.1/kafka_2.10-0.10.2.1.tgz

  tar zxvf kafka_2.10-0.10.2.1.tgz

  sudo mv kafka_2.10-0.10.2.1 /opt/kafka/

  2.  nohup bin/kafka-server-start.sh config/server.properties

启动服务后,新开终端,后续操作

  1.创建一个主题  bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

  2.测试创建主题成功否  bin/kafka-topics.sh --list --zookeeper localhost:2181

  3.启动生产者  bin/kafka-console-producer.sh --broker-list localhost(本地主机):9092 --topic test

  4.新终端窗口,启动消费者  bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

在生产者终端输入数据,消费者马上就会消费显示出来

原文地址:https://www.cnblogs.com/DowneyJr/p/7649023.html