轉載請注明出處：http://blog.csdn.net/l1028386804/article/details/78383783
今天，我們給大家帶來一篇如何利用Kafka的API進行用戶端程式設計的文章，這篇文章很簡單，就是利用Kafka的API建立一個生産者和消費者，生産者不斷向Kafka寫入消息，消費者則不斷消費Kafka的消息。下面是具體的執行個體代碼。
這個類很簡單，隻是存放了兩個常量，一個是話題TOPIC，一個是線程數THREADS
這個類的主要作用就是向Kafka寫入相應的消息，并且将消息寫入wordcount話題。
這個類的主要作用就是消費Kafka中wordcount話題的消息。
首先，運作消費者類ConsumerDemo
運作結果如下：
沒有列印任何資訊。
此時，我們運作生産者類ProducerDemo
我們再次打開消費者的控制台檢視如下：
列印出了生産者生産的消息。
至此，Kafka簡單用戶端程式設計執行個體結束。