Python操作kafka實現數據定時推送和獲取，並解決中文亂碼問題

上篇介紹了kafka環境的搭建以及實現了Python如何簡單操作kafka。本篇實現如何定時向kafka推送和接收數據，並解決了中文亂碼問題。 設置Producer每隔5秒推送一次數據，Consumer每隔60秒去獲取一次數據，這樣Consumer每次消費的就是12條數據（60/5=12），截圖實例中也有展示。 #------------------------------------------

>>阅读原文<<