kafka的簡單配置與使用

二、進入kafka資料夾下的config，配置zookeeper即zookeeper.properties

三、配置kafka，即server.properties

四、啟動zookeeper

bin/zookeeper-server-start.sh config/zookeeper.properties

bin/kafka-server-start.sh config/server.properties

bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

>hello
>text
>this is a test message
>this is a text

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

hello
text
this is a test message
this is a text

kafka的簡單使用

mkdir logs broker的全域性唯一編號，不能重複，只能是整型，每個機器都不一樣 broker.id 0 刪除topic功能使用 delete.topic.enable true 處理網路請求的執行緒數量 num.network.threads 3 用來處理磁碟io的現成數量 num.io...

Kafka學習 一 配置及簡單命令使用

kafka是乙個scala實現的分布式訊息中介軟體,當中涉及到的相關概念例如以下 附加個圖說明下 broker 集群總的節點 配置 broker.id 唯一確定的乙個int 型別數字 log.dirs 儲存kafka資料,預設路徑 為 tmp kafka logs port comsumer連線的埠...

Kafka簡單使用示例

sh bin zookeeper server start.sh config zookeeper.properties 啟動zookeeper sh bin kafka server start.sh config server.properties properties properties n...