使用kafka內建zk啟動以及測試
功能驗證：
啟動kafka內嵌的zk（前台啟動）：bin/zookeeper-server-start.sh config/zookeeper.properties
啟動kafka服務: bin/kafka-server-start.sh config/server.properties
建立 topic :
bin/kafka-topics.sh --zookeeper localhost:2181 --create --topic test1 --partitions 3 --replication-factor 1
檢視topic資訊：
bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic test1
檢視topic列表：
bin/kafka-topics.sh --list --zookeeper localhost:2181
傳送訊息:
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test1
接收訊息：
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test1（親測可用，version：kafka_2.11-2.1.0）
tips：
lsof -i:2181 （檢視2181埠是否被監聽）
lsof -i:9092（檢視9092埠是否被監聽）
Linux快速體驗
目錄結構 根目錄，根目錄下一般只存放子目錄，不存放檔案。bin 存放可執行的二進位制檔案，如常用的命令ls tar mv cat等。boot 存放linux系統啟動時需要的一些檔案。dev 存放linux系統下的裝置檔案，訪問該目錄下某個 檔案，相當於訪問某個裝置。etc 存放系統配置檔案。home...
Linux快速體驗
目錄結構 bin 存放可執行的二進位制檔案，如常用的命令ls tar mv cat等。boot 存放linux系統啟動時需要的一些檔案。dev 存放linux系統下的裝置檔案，訪問該目錄下某個檔案，相當於訪問某個裝置。etc 存放系統配置檔案。home 系統預設的使用者目錄。lib 系統使用的函式庫...
kafka搭建 快速搭建Kafka服務
搞流處理的話，無論如何是繞不過kafka的了，還好kafka是乙個概念比較好理解的架構模型。我覺得官方的這三張圖已經很好地把模型結構給闡述清楚了。發布 訂閱模型 實現訊息寫入與訊息讀取解耦。kafka相當於是乙個訊息緩衝池 2.日誌檔案順序結構 kafka的高吞吐量就是依賴順序寫入 當然還包括了一些...