kafka的常见操作。
先确保计算机上已经装了jdk。
修改计算机的名称。先输入hostname进行查看
为什么要查看这个主机名呢？
答: 这是当有远程计算机需要连接本机的kafka时，需要在远程计算机hosts中配置:
解压安装包：
tar xvf kafka_2.12-1.0.0.tgz
1、修改kafka中的zookeeper的配置。
config/zookeeper.properties
2、修改kafka的配置，config/server.properties
3、启动zookeeper
bin/zookeeper-server-start.sh config/zookeeper.properties &
4、启动kafka
bin/kafka-server-start.sh config/server.properties &
5、创建一个topic
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic returnflow
6、查看topic
bin/kafka-topics.sh --list --zookeeper localhost:2181
7、创建生产者， Send some messages
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic returnflow
8、 启动一个客户端(消费者)
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic returnflow --from-beginning
停止kafka
bin/kafka-server-stop.sh