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)
相關文章
相關標籤/搜索