kafka详解（2）：Kafka API实战

一、环境准备 （1）建立一个java工程，并将kafka安装包libs下的jar包拷贝到工程的lib目录下 （2）启动zk和kafka集群，在kafka集群中打开一个消费者 bin/kafka-console-consumer.sh --zookeeper hadoop03:2181 --topic testKafkajava 二、Kafka生产者JavaAPI 2.1 建立生产者（过期的API）

>>阅读原文<<