Kafka Java API操做topic

Kafka官方提供了兩個腳原本管理topic，包括topic的增刪改查。其中kafka-topics.sh負責topic的建立與刪除；kafka-configs.sh腳本負責topic的修改和查詢，但不少用戶都更加傾向於使用程序API的方式對topic進行操做。   上一篇文章中提到了如何使用客戶端協議(client protocol)來建立topic，本文則使用服務器端的Java API對top

>>阅读原文<<