kafka 學習筆記（四）之Python客戶端

阿新 • • 發佈：2019-02-06

今天看看Python客戶端。

程式碼在github上，和以前一樣，我們用github上寫好的程式碼進行測試

https://github.com/mumrah/kafka-python

pip install git+git://github.com/mumrah/kafka-python

先確保機器上已經安裝了python

輸入命令：python

[[email protected] kafka-python]# python
Python 2.6.6 (r266:84292, Jan 22 2014, 09:42:36)
[GCC 4.4.7 20120313 (Red Hat 4.4.7-4)] on linux2
Type "help", "copyright", "credits" or "license" for more information.
>>>

先來使用Producer

>>> from kafka import KafkaClient, SimpleProducer, SimpleConsumer

>>> kafka = KafkaClient("localhost:9092")

producer = SimpleProducer(kafka)

producer.send_messages("test1","Hello world!")

值得注意的是，Python客戶端不需要想Java客戶端一樣連線zookeeper，Python客戶端的執行和Java版的是兩個project，所以方法不一樣。

用kafka自帶的consumer console，我們可以看到輸出的message

同樣，Python客戶端也有一些可控的引數，例如是否同步：

producer = SimpleProducer(kafka,async=True)

producer = SimpleProducer(kafka,req_acks=SimpleProducer.ACK_AFTER_LOCAL_WRITE)

還可以獲得response，例如

response = producer.send_messages("test1","Hello world!")

response[0].offset

得到offset

再看看Consumer

consumer = SimpleConsumer(kafka,"python","test1")

for msg in consumer:

print(msg)

結果如圖：

然後讓我們優雅的退出

kafka.close()

exit()

Kafka 的Python客戶端介紹完了，enjoy！

kafka 學習筆記（四）之Python客戶端

今天看看Python客戶端。程式碼在github上，和以前一樣，我們用github上寫好的程式碼進行測試 https://github.com/mumrah/kafka-python pip install git+git://github.com/mumrah/kafk

ESP32學習筆記（四）之I2C總線

oid 操作系統 parameter ica basis condition 技術分享 col rto 上一篇帖子我們了解了一下ESP32運行多任務的操作以及現象，其實也就是一個實時操作系統。那麽，這篇帖子我們就結合“LM75a”溫度傳感器來學習一下ESP32的IIC總線吧

Servlet學習筆記（四）之請求轉發與重定向（RequestDispatcher與sendRedirect）

ServletContext可以實現請求轉發（ServletContext請求轉發相關內容見之前部落格：http://blog.csdn.net/megustas_jjc/article/details/53191657），request也可以。HttpServletRequest 和 ServletCont

Docker學習筆記（四）之容器檢視啟動終止刪除

檢視 docker ps 主要有些引數要說一下 1. 不加引數，表示檢視當前正在執行的容器 2. -a，檢視所有容器包括停止狀態的容器 3. -l，檢視最新建立的容器 4. -n=x，檢視最

Android學習筆記（四）之碎片化Fragment實現仿人人客戶端的側邊欄

其實一種好的UI佈局，可以使使用者感到更加的親切與方便。最近非常流行的莫過於側邊欄了，其實我也做過很多側邊欄的應用，但是那些側邊欄的使用我都不是很滿意，現在重新整理，重新寫了一個相對來說我比較滿意的側邊欄，其中運用的就是android3.0版本之後新加的Fragme

Kafka 學習筆記（八）之producer讀取file

要想讓Kafka用到實際中，就需要學會讓Kafka從檔案中讀取內容，傳送到topic裡，以供consumer讀取。我們以前的幾篇，自己產生data的，不是從file中讀的。之前先下載好scp，scp是secure copy的簡寫，用於在Linux下進行遠端拷貝檔案的命令。

《機器學習實戰》學習筆記（四）之Logistic（上）基礎理論及演算法推導、線性迴歸，梯度下降演算法

轉載請註明作者和出處：http://blog.csdn.net/john_bh/ 執行平臺： Windows Python版本： Python3.6 IDE： Sublime text3 一、概述 Logistic迴歸是統計學習中的經典

Opencv3程式設計入門學習筆記（四）之split通道分離Debug過程中0xC0000005記憶體訪問衝突問題

這是筆者學習《Opencv3程式設計入門》的第四篇部落格，這篇部落格主要是解決在Windows系統下VS 2013中Debug含有split分離通道色彩函式時報出的0xC0000005記憶體訪問衝突問題，問題表現如下面第一幅圖所示。剛剛遇到這個問題的時候

Kafka學習筆記（四）—— API使用

1、Producer API 1.1 訊息傳送流程 Kafka的Producer傳送訊息採用的是非同步傳送的方式。在訊息傳送的過程中，涉及到了兩個執行緒——main執行緒和Sender執行緒，以及一個執行緒共享變數——RecordAccumulator。main執行緒將訊息傳送給RecordAccumulat

Python學習筆記（四）列表生成式_生成器

rec triangle 小寫 ont 無限 end clas 普通執行過程筆記摘抄來自：https://www.liaoxuefeng.com/wiki/0014316089557264a6b348958f449949df42a6d3a2e542c000/001431

Unity3D之Mecanim動畫系統學習筆記（四）：Animation State

大致面板輸入 jpg any 動畫播放速度 nsf 顯示動畫的設置我們先看看Animation Clip的一些設置： Loop time：動畫是否循環播放。下面出現了3個大致一樣的選項： Root Transform Rotation：表示為播放動畫

Andrew Ng機器學習課程筆記（四）之神經網絡

python學習筆記（四）-數據類型

rand 兩個 urn 浪費 line 平年 randint .com .cn 0. 在 Python 中的數據類型詳解 http://www.cnblogs.com/scios/p/8026576.html 1. 為什麽布爾類型(bool)的 True 和 False 分

python學習筆記（四）字符串及字符串操作

默認小寫字母是不是 swap git 查找字符英文去掉 title 字符串　　字符串可以存任意類型的字符串，比如名字，一句話等等。字符串還有很多內置方法，對字符串進行操作，常用的方法如下： 1 name1=‘hello world‘ 2 print(nam

day3-python學習筆記（四）

end tar upper date update size upd sdi reat 字符串方法 #字符串這些方法都不會改變原來字符串的值name = ‘beSTtest‘# new_name = name.strip()#默認是去掉空格和換行符# new_name =

python學習筆記（六）之集合1

什麽 mos pty this ash 筆記 sca sel 指定 python學習筆記（六）之集合1python中各種類型與其各種方法，都可以使用下面的方法查到：(1)交互模式下用dir()或者help()(2)google集合特點：英語set，有的可變，有的不可變；元素

python學習筆記（六）之集合2

lock true 可變對象屬於 attribute 聯盟 per rec python學習筆記（七）之集合2不變的集合在”python學習筆記（六）之集合1“中以set()來建立集合，這種方式所創建的集合都是可原地修改的集合，或者說是可變的，也就是說是unhashab

python學習筆記（八）之運算符

技術 ima 學習表達式 water nag proc 說明 ddc python學習筆記（八）之運算符算術運算符比較運算符邏輯運算符（1）布爾運算（2）復雜的布爾表達式說明：以上內容摘自《跟老齊學python》python學習筆記（八）之運算符

python學習筆記（九）之語句1

如果 red 開始就是整除 for 循環個數 hello 基本 python學習筆記（九）之語句1printpython2中，print是一個語句，python3中它是一個函數。實例1: >> print "hello,world!"

python的學習筆記（0）之循環的使用1

循環條件 back 技術分享 -s 這就是相同直接用法深入　　這是我第一次正式的開始學習這門語言，雖然之前也多多少少接觸過一點，但是一直沒有深入的學習和研究過，所以我打算從今天起準備開始由淺入深的學習下這門語言。　　python這門語言和其他語言相比最大的特點就

kafka 學習筆記（四）之Python客戶端

相關推薦