该文章描述了在CentOS系统中下载和安装snappy-devel的过程，然后使用pip安装python-snappy和kafka-python库。接着，它展示了一个Python脚本，创建了一个Kafka消费者来监听topic1主题，并打印接收到的消息。
1、下载snappy-devel
wget http://mirror.centos.org/centos/7/os/x86_64/Packages/snappy-devel-1.1.0-3.el7.x86_64.rpm
2、安装snappy-devel
sudo rpm -ivh snappy-devel-1.1.0-3.el7.x86_64.rpm
3、安装python-snappy
pip install python-snappy
4、安装kafka-python
pip install kafka-python
测试代码：
from kafka import KafkaConsumer
consumer = KafkaConsumer('topic1',bootstrap_servers=['127.0.0.1:9092'])
for message in consumer:
print(message)
测试效果：
ConsumerRecord(topic='topic1', partition=0, offset=47, timestamp=1673514575286, timestamp_type=0, key=None, value=b'56', headers=[], checksum=None, serialized_key_size=-1, serialized_value_size=2, serialized_header_size=-1)
扫一扫
被折叠的 条评论
为什么被折叠?
到【灌水乐园】发言
