PythonでKafkaから最新データを消費する方法は何ですか。

2年 ago
桜, 春樹
1 minute

Kafkaの最新データを消費するためには、kafka-pythonライブラリを使用することができます。以下は簡単なサンプルコードです：

from kafka import KafkaConsumer

# 配置Kafka连接信息
bootstrap_servers = 'localhost:9092'  # Kafka服务器地址和端口号
topic = 'my_topic'  # Kafka主题名称
group_id = 'my_group'  # 消费者组ID

# 创建KafkaConsumer对象
consumer = KafkaConsumer(topic,
                         bootstrap_servers=bootstrap_servers,
                         group_id=group_id,
                         auto_offset_reset='latest')

# 消费最新数据
for message in consumer:
    print(message.value)

コードの上部には、まずKafkaへの接続情報を設定する必要があります。これには、Kafkaサーバーのアドレスとポート番号、トピック名、および消費者グループIDが含まれます。次に、KafkaConsumerオブジェクトを作成し、消費するトピック、Kafkaサーバーのアドレス、消費者グループID、およびauto_offset_resetパラメータを’latest’に設定して、最新のオフセットから消費を開始します。

最後に、消費者オブジェクトをforループで反復処理し、各メッセージの値を印刷します。これにより、Kafkaの最新データを消費できます。

bannerAds