kafka集群環境搭建完成後，整合到專案開發中，我需要給某個topic傳送訊息，以及監聽消費該topic中的訊息，難道我需要事先用kafka命令先去伺服器建立乙個topic，然後再供專案使用嗎？
有沒有我在專案配置檔案裡指定kafka的topic=***，然後啟動服務的時候，kafka就可以自動幫我建立好呢？
其實，在配置檔案裡指定好kafka的topic之後，呼叫send方法會自動幫我們建立好topic，只是建立的topic預設是1個副本和1個分割槽的，這一般不能滿足我們的要求，所以我們還需要在kafka的server.properties裡增加或修改以下引數：
num.partitions=
3auto.create.topics.enable=
true
default
.replication.factor=
3
另外，也可以通過一些api幫我們建立好主題，這個就需要自己手動去實現建立topic的方法。
Kafka刪除主題詳解
在kafka的使用 測試過程中，可能老是會遇到想要刪除某個主題的需求，但是由於對其內部機制不夠了解，總是無法有效的刪除主題。今天這篇文章詳細討論如何徹底的刪除乙個主題。在kafka的broker端的配置引數中有這樣乙個引數 delete.topic.enable，必須將它設定為true才能夠刪除ka...
Kafka 位移主題詳解
建立時機 提交策略 刪除過期訊息優點 缺點kafka中的內部位移主題是 consumer offsets。offset訊息 簡單的可以理解為 key value 註冊訊息 用來註冊 儲存 consumer group資訊的訊息 墓碑訊息 作用用於刪除 group 過期位移甚至是刪除 group 的訊...
kafka刪除主題資料和刪除主題
1 刪除主題 在server.properties中增加設定，預設未開啟 delete.topic.enable true 刪除主題命令 bin kafka topics delete topic test zookeeper localhost 2181 2 刪除主題資料 如果想保留主題，只刪除主...