柚子快報(bào)激活碼778899分享：kafka 學(xué)習(xí)，筆記

http://yzkb.51969.com/

前置條件，需要安裝Java

1 去官網(wǎng)下載Kafka安裝包

2 將安裝解壓縮到C盤(pán)根目錄

3 在cmd命令行窗口進(jìn)入kafka是根目錄

cd c:\kafka_2.12-3.4.0

4 啟動(dòng)zookeeper服務(wù)

卡夫卡的運(yùn)行需要zookeeper的支持，一般來(lái)說(shuō)我們需要安裝zookeeper，但是卡夫卡有內(nèi)置的zookeeper服務(wù)，所以在這里，沒(méi)有額外安裝zookeeper。

.\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties

啟動(dòng)成功的界面。主要，要保持這個(gè)窗口一直運(yùn)行，不可以關(guān)閉。

5 打開(kāi)第二個(gè)cmd命令行窗口，進(jìn)入卡夫卡安裝目錄

cd c:\kafka_2.12-3.4.0

6 啟動(dòng)卡夫卡服務(wù)

.\bin\windows\kafka-server-start.bat .\config\server.properties

7 測(cè)試卡夫卡

新建一個(gè)cmd命令行窗口，（注意，前面兩個(gè)cmd窗口不可以關(guān)閉）進(jìn)入卡夫卡的安裝目錄

cd c:\kafka_2.12-3.4.0

.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic topic_test

?8 檢測(cè)7中的命令是否執(zhí)行成功

.\bin\windows\kafka-topics.bat --list --zookeeper localhost:2181

?說(shuō)明創(chuàng)建topic成功，名稱為topic_test

9 創(chuàng)建一個(gè)producer來(lái)產(chǎn)出消息

.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic topic_test

i love kafka

10 在新建一個(gè)cmd窗口

cd c:\kafka_2.12-2.4.0

.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic topic_test --from-beginning

?

# -*- coding: utf-8 -*-

# ---

# @Software: PyCharm

# @File: kafka_producer01.py

# @Site:

# @Time: Apr 28, 2023

# ---

from kafka import KafkaProducer

# 鏈接卡夫卡

producer = KafkaProducer(bootstrap_servers='localhost:9092')

# 發(fā)送內(nèi)容，必須是bytes類型

msg = "Hello kafka".encode('utf-8')

# 發(fā)送的topic為test

producer.send('test', msg)

producer.close()

?

# -*- coding: utf-8 -*-

# ---

# @Software: PyCharm

# @File: kafka_consumer01.py

# @Site:

# @Time: Apr 28, 2023

# ---

from kafka import KafkaConsumer

consumer = KafkaConsumer('test', bootstrap_servers=['localhost:9092'], group_id=None, auto_offset_reset='smallest')

for msg in consumer:

recv = "%s:%d:%d:key=%s value=%s" % (msg.topic, msg.partition, msg.offset, msg.key, msg.value)

print(recv)

'''備注

1 啟動(dòng)zookeeper服務(wù)和kafka服務(wù)，

2 先執(zhí)行kafka_producer01.py

3 再執(zhí)行kafka_consumer01.py

4 可以看到屏幕上打印出“Hello kafka”

'''

?

柚子快報(bào)激活碼778899分享：kafka 學(xué)習(xí)，筆記

http://yzkb.51969.com/

參考鏈接