生成一段访问 Kafka 的 python 代码

以下为访问 Kafka 的 Python 代码示例：

from kafka import KafkaProducer, KafkaConsumer

# 创建生产者
producer = KafkaProducer(bootstrap_servers=['localhost:9092'])

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

# 创建消费者
consumer = KafkaConsumer('topic_name', bootstrap_servers=['localhost:9092'])

# 读取消息
for message in consumer:
    print(message.value)

需要使用 `kafka-python` 库来实现 Kafka 的访问。首先通过 `KafkaProducer` 类创建生产者对象，并指定 Kafka 的服务器地址（bootstrap_servers）。然后使用 `send` 方法将消息发送到指定主题。接着通过 `KafkaConsumer` 类创建消费者对象，同样需要指定服务器地址和主题。最后通过 for 循环读取消息并进行处理。

相关问题

生成一段代码使用接收Kafka消息

当然可以，以下是一个简单的示例代码：

from kafka import KafkaConsumer

consumer = KafkaConsumer('my-topic', bootstrap_servers=['localhost:9092'])

for message in consumer:
    print(message.value.decode('utf-8'))

这段代码使用 KafkaConsumer 模块来接收名为 'my-topic' 的 Kafka 消息，并将其打印到控制台上。你可以根据自己的需求修改代码。