菜鳥先飛之Kafka安裝配置和一些基本操作

準備好安裝包：kafka_2.11-2.0.0.tgz

# 拖入本地並解壓

tar -zxf kafka_2.11-0.11.0.2.tgz

# 改名

mv kafka_2.11-0.11.0.2 kafka

# 切換至kafka配置檔案目錄

cd /opt/soft/kafka/config

# 修改配置檔案server.properties(消費者配置)

vi server.properties

# 配置環境變數

vi /etc/profile 

# kafka

export kafka_home=/opt/soft/kafka

export path=$path:$kafka_home/bin

source /etc/profile

# 後台執行kafka

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

# 建立主題

# 檢視已建立的topic 

kafka-topics.sh --list --zookeeper 127.0.0.1:2181

# 建立乙個訊息生產者

kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic test

# 新開乙個介面建立乙個消費者

kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic test --from-beginning

# 檢視topic具體描述 包括 partition leader replicas isr

kafka-topics.sh --zookeeper 127.0.0.1:2181 --describe --topic test

# 刪除topic

kafka-topics.sh --zookeeper 127.0.0.1:2181 --delete --topic test

菜鳥先飛之JAVA 方法

提高 的復用性 完成特定功能的 塊。修飾符 返回值型別 方法名 引數型別 引數名1,引數型別 引數名2.方法體語句 return返回值 修飾符 目前就用 public static。後面我們再詳細的講解其他的修飾符。返回值型別 就是功能結果的資料型別。方法名 符合命名規則即可。方便我們的呼叫。引數 ...

Kafka安裝配置

kafka執行依賴 zookeeper，如未安裝zookeeper請參考 zookeeper安裝使用 kafka版本問題 這又是一大坑 如果你的storm安裝的是1.0.x系列或更低的版本，建議你安裝0.8.x.x版本的kafka。如果你的storm安裝的是1.1.x系列或更高的版本，建議你安裝0....

kafka安裝配置

一.zookeeper部署 tar xvf zookeeper 3.4.6.tar.gz mv zookeeper 3.4.6 zookeeper chown r root root zookeeper 2.修改配置 cd zookeeper conf cp zoo sample.cfg zoo.c...