柚子快報(bào)激活碼778899分享：分布式 Kafka基本使用

http://yzkb.51969.com/

Kafka基本使用

1.查看Kafka的進(jìn)程是否在運(yùn)行

#命令行終端中運(yùn)行如下命令

ps -ef | grep kafka

或者

ps aux | grep kafka | grep -v grep

find / -iname kafka-server-start.sh

cd /usr/local/kafka/bin/

#啟動kafka

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

?2.Kafka默認(rèn)使用9092端口提供服務(wù)，可以使用以下命令查看該端口是否已經(jīng)打開

netstat -tnlp | grep 9092

?或者jps

如果Kafka進(jìn)程正在運(yùn)行，則會出現(xiàn)一個類似于以下的輸出：

?

?zookeeper 配置

find / -iname zoo.cfg

cd /usr/local/zookeeper/conf

kafka 配置

find / -iname server.properties

cd /usr/local/kafka/config/

待更新

?

? 啟動zookeeper

find / -iname zkServer.sh

cd /usr/local/zookeeper/bin/

#修改配置重新啟動

./zkServer.sh restart

?

?查看 zookeeper 是否正常啟動成功

sudo netstat -tulnp | grep 2181

ps -ef | grep zookeeper

查看Kafka日志

tail /usr/local/kafka/logs/server.log

?

使用jps命令查看是否正常了

3.測試Kafka服務(wù)

可以通過在命令行終端中執(zhí)行一些Kafka命令來測試Kafka服務(wù)是否正常工作。例如，可以使用以下命令查看Kafka當(dāng)前可用的主題列表：

/usr/local/kafka/bin/kafka-topics.sh --zookeeper localhost:2181 --list

啟動生產(chǎn)者

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

?創(chuàng)建kafka生產(chǎn)者：

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

停止后重新開啟

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

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

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

?

啟動消費(fèi)者

./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic helloKafka

創(chuàng)建kafka消費(fèi)者?

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

kafka可視化工具Kafka

?

查看topic分區(qū)列表及分區(qū)leader位置信息：

查看topic的消息內(nèi)容。此功能會去每個分區(qū)獲取固定數(shù)量（右下角設(shè)置）的消息，可以看到消息分區(qū)、offset消息位置、key、value、消息時間戳信息。下半部分還能查看到消息的長度（字節(jié)）。

設(shè)置字符格式? ?

?

報(bào)錯1

Kafka配置使用?

1.進(jìn)入Kafka安裝目錄

cd /usr/local/kafka/bin

2.打開server.properties配置文件

find / -iname server.properties

cd /usr/local/kafka/config/

修改log.retention.check.interval.ms=2000。作用：縮短每次檢查Log時間，確保輸入刪除命令后Kafka可短時間內(nèi)刪除掉Topic。

Kafka重啟前的準(zhǔn)備

在重啟Kafka之前，需要做好以下幾個方面的準(zhǔn)備：

1. 保存好當(dāng)前Kafka集群的數(shù)據(jù)；

2. 停止所有的生產(chǎn)者和消費(fèi)者；

3. 關(guān)閉所有Kafka連接，在重啟前確保沒有任何請求發(fā)送到Kafka上。

./kafka-server-stop.sh /usr/local/kafka/config/server.properties

?

? ?如果kafka服務(wù)沒有停止，則使用以下命令終止進(jìn)程：

kill -9 `ps ax | grep -i 'kafka' | grep -v grep | awk '{print $1}'`

二、重啟Kafka節(jié)點(diǎn)

重啟Kafka節(jié)點(diǎn)，通常需要按照以下步驟進(jìn)行：

1. 停止當(dāng)前節(jié)點(diǎn)上的Kafka服務(wù):

2. 確認(rèn)Kafka服務(wù)已完全停止：

ps -ef | grep kafka

3. 啟動Kafka服務(wù)：

#前臺運(yùn)行：

./kafka-server-start.sh /usr/local/kafka/config/server.properties

#后臺運(yùn)行：

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

柚子快報(bào)激活碼778899分享：分布式 Kafka基本使用

http://yzkb.51969.com/

相關(guān)文章