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)