kafka

cooolr 于 2021-03-24 发布

pip install kafka-python

from kafka import KafkaProducer
from kafka.errors import KafkaError

producer = KafkaProducer(bootstrap_servers='192.168.1.243:6667,192.168.1.158:6667')

try:
    producer.send("news_characteristic", b'{"newsId":123445}')
except KafkaError as e:
    print(e)
finally:
    producer.close()
from kafka import KafkaConsumer

consumer = KafkaConsumer('news_characteristic', group_id = 'test_group2', bootstrap_servers='192.168.1.243:6667')
for message in consumer:
    print(message)