五分鐘快速從無到有測試kafka....
感謝Docker.....
使用 https://github.com/spotify/docker-kafka docker-image
docker run -p 2181:2181 -p 9092:9092 --name poc-kafka --env ADVERTISED_HOST=localhost --env ADVERTISED_PORT=9092 spotify/kafka
一行解決環境安裝與設定
回到程式撰寫部分，把python裝上 kafka 套件
pip install kafka-python
寫一個模擬丟資料的(publish)
from kafka import KafkaProducer
import datetime
producer = KafkaProducer(bootstrap_servers='localhost:9092')
for _ in range(100):
producer.send('foobar', str(datetime.datetime.now()))
在寫一個模擬接收(SUBSCRIBE)
from kafka import KafkaConsumer
consumer = KafkaConsumer('foobar')
for msg in consumer:
print msg
分別執行，應該會在接收的地方收到kafka封裝後的msg，裡面的value就是傳送程式的時間字串
打完收工....
