Sample Producer and Consumer Apache Kafka in Python
Pada posting berjudul " Sample Producer and Consumer Apache Kafka in Python " ini penulis berikan sample untuk membuat producer dan consumer di python menggunakan librari kafka-python=2.0.2 Kita bisa melakukan instalasi librari tersebut menggunakan perintah pip install kafka-python Sebelum kita melakukan pembuatan producer dan consumer menggunakan python , pastikan kita telah menginstall dan mengkonfigurasi Apache Kafka di komputer kita kemudian jalankan zookeeper dan kafka terlebih dahulu. Dibawah ini adalah sample producer menggunakan python : from time import sleep from kafka import KafkaProducer producer = KafkaProducer(bootstrap_servers=['localhost:9092'], api_version=(2, 0, 2)) datas = [1000000,2000000,3000000,4000000,5000000] for i in range(1000): for e in datas: data = {'number' : e} print(i, e, data, type(bytes(str(e), 'utf-8'))) producer.send('TestTopic', bytes(str(e), 'utf-8'))