文章目錄

• • • • • 一、KAFKA 啟動與監(jiān)控
        • 二、KAFKA 主題創(chuàng)建于查看生產(chǎn)與消費
        • • 2.1. 查看主題列表
          • 2.2. 創(chuàng)建主題
          • 2.3. 查看主題信息
          • 2.4. 主題信息分析
        • 三、KAFKA 主題創(chuàng)建于查看生產(chǎn)與消費
        • • 3.1. 客戶端監(jiān)聽消息
          • 3.2. 生產(chǎn)消息
          • 3.3. 從頭監(jiān)聽消息

一、KAFKA 啟動與監(jiān)控

# 后臺啟動kafka kafka-server-start.sh -daemon /app/kafka_2.12-2.8.0/config/server.properties# 監(jiān)控kafka ps -aux |grep kafka# 日志存放目錄 cd /var/gblfy/kafka/kafka-logs[root@bogon kafka-logs]# pwd /var/gblfy/kafka/kafka-logs [root@bogon kafka-logs]# ll 總用量 4 -rw-r--r--. 1 root root 0 9月 15 13:25 cleaner-offset-checkpoint -rw-r--r--. 1 root root 0 9月 15 13:25 log-start-offset-checkpoint -rw-r--r--. 1 root root 54 9月 15 13:25 meta.properties -rw-r--r--. 1 root root 0 9月 15 13:25 recovery-point-offset-checkpoint -rw-r--r--. 1 root root 0 9月 15 13:25 replication-offset-checkpoint

二、KAFKA 主題創(chuàng)建于查看生產(chǎn)與消費

2.1. 查看主題列表

kafka-topics.sh --zookeeper localhost:2181/mykafka --list

2.2. 創(chuàng)建主題

創(chuàng)建主題指定主題名稱、該主題有幾個分區(qū)，每個分區(qū)有幾個副本

副本就是為了提高高可用，主從切換，要求一個分區(qū)的不同副本必須在不同的服務(wù)器上，否則沒有意義

# 創(chuàng)建一個主題名稱為topic_1 該主題分區(qū)1個分區(qū) ，該分區(qū)有1個副本 kafka-topics.sh --zookeeper localhost:2181/mykafka --create --topic topic_1 --partitions 1 --replication-factor 1 # 創(chuàng)建一個主題名稱為topic_2 分區(qū)個數(shù)為5個 ，每個分區(qū)各有1個副本 kafka-topics.sh --zookeeper localhost:2181/mykafka --create --topic topic_2 --partitions 5 --replication-factor 1

2.3. 查看主題信息

# 查看主體名稱為topic_1的具體信息 kafka-topics.sh --zookeeper localhost:2181/mykafka --describe --topic topic_1# 查看主體名稱為topic_2的具體信息 kafka-topics.sh --zookeeper localhost:2181/mykafka --describe --topic topic_2

2.4. 主題信息分析

[root@bogon kafka-logs]# kafka-topics.sh --zookeeper localhost:2181/mykafka --describe --topic topic_1 Topic:topic_1 PartitionCount:1 ReplicationFactor:1 Configs:Topic: topic_1 Partition: 0 Leader: 0 Replicas: 0 Isr: 0 當前topic_1主題，有1個分區(qū)，0號分區(qū)，這個分區(qū)在0號服務(wù)器上，一個副本，在0號服務(wù)器上 [root@bogon kafka-logs]# kafka-topics.sh --zookeeper localhost:2181/mykafka --describe --topic topic_2 Topic:topic_2 PartitionCount:5 ReplicationFactor:1 Configs:Topic: topic_2 Partition: 0 Leader: 0 Replicas: 0 Isr: 0Topic: topic_2 Partition: 1 Leader: 0 Replicas: 0 Isr: 0Topic: topic_2 Partition: 2 Leader: 0 Replicas: 0 Isr: 0Topic: topic_2 Partition: 3 Leader: 0 Replicas: 0 Isr: 0Topic: topic_2 Partition: 4 Leader: 0 Replicas: 0 Isr: 0 # 主題topic_2，該主題有5個分區(qū)，分別是0/1/2/3/4/5號分區(qū)，每個分區(qū)各有一個副本，每個分區(qū)都在0號服務(wù)器上

三、KAFKA 主題創(chuàng)建于查看生產(chǎn)與消費

3.1. 客戶端監(jiān)聽消息

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

3.2. 生產(chǎn)消息

# kafka-console-producer.sh --broker-list localhost:9092 --topic topic_1# 在實時窗口中，生產(chǎn)消息，消費者就會實時監(jiān)聽消息

如下圖所示：

3.3. 從頭監(jiān)聽消息

把消費者關(guān)閉，重新啟動，默認消費者就會之監(jiān)聽在此時間之后的消息，之前的消息不能監(jiān)聽，那如果有需求需要監(jiān)聽以前的所有消息，那該如何處理呢？

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topic_1 --from-beginning

總結(jié)

以上是生活随笔為你收集整理的KAFKA 最新版 Shell API单机生产与消费的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。