黑猴子的家：Kafka API

2018-10-10 本文已影响73人黑猴子的家

1）在eclipse中创建一个java工程

2）在工程的根目录创建一个lib文件夹

3）解压kafka安装包，将安装包libs目录下的jar包拷贝到工程的lib目录下，并build path。

4）启动zookeeper和kafka集群，在kafka集群中打开一个消费者

[victor@node1 kafka]$ bin/kafka-console-consumer.sh --zookeeper node1:2181 \
--topic first