centos下安装、启动、测试kafka

下载kafka：

wget http://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.2.0/kafka_2.12-2.2.0.tgz

  842  tar zxvf kafka_2.12-2.2.0.tgz

  844  cd  kafka_2.12-2.2.0/

  846  kafka_2.12-2.2.0 kafka_2.12-2.2.0 kafka_2.12-2.2.0

  847  kafka_2.12-2.2.0/libs/osgi-resource-locator-1.0.1.jar

启动

 /opt/kafka_2.12-2.2.0/bin/kafka-server-start.sh config/server.properties &

注册主题：

/opt/kafka_2.12-2.2.0/bin/kafka-console-producer.sh --broker-list 192.168.153.118:9092 --topic test

启动生产者：

 /opt/kafka_2.12-2.2.0/bin/kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic test

启动消费者：

/opt/kafka_2.12-2.2.0/bin/kafka-console-consumer.sh --topic test --bootstrap-server 127.0.0.1:9092 --from-beginning