kafka生产者消费者

Kafka是一个分布式流处理平台，它可以处理高吞吐量的实时数据。Kafka的生产者将消息发布到主题中，而消费者则从主题中订阅消息。以下是Kafka生产者和消费者的介绍和演示：

1. Kafka生产者

Kafka生产者将消息发布到主题中。以下是一个简单的Python示例，演示如何使用Kafka生产者API将消息发布到主题中：

from kafka import KafkaProducer

# 创建Kafka生产者实例
producer = KafkaProducer(bootstrap_servers='localhost:9092')

# 发送消息到主题
producer.send('test_topic', b'Hello, Kafka!')

2. Kafka消费者

Kafka消费者从主题中订阅消息。以下是一个简单的Python示例，演示如何使用Kafka消费者API从主题中订阅消息：

from kafka import KafkaConsumer

# 创建Kafka消费者实例
consumer = KafkaConsumer('test_topic', bootstrap_servers='localhost:9092')

# 从主题中获取消息
for message in consumer:
    print(message.value.decode('utf-8'))