怎么利用python网kafka里面生产消息和消费消息

可以使用Python中的kafka-python库来进行Kafka消息的生产和消费。下面是一个简单的示例代码:

生产消息:

from kafka import KafkaProducer

producer = KafkaProducer(bootstrap_servers=['localhost:9092'])

producer.send('my_topic', b'my_message_bytes')

消费消息:

from kafka import KafkaConsumer

consumer = KafkaConsumer('my_topic', bootstrap_servers=['localhost:9092'])

for message in consumer:
    print(message.value)

其中，`bootstrap_servers`参数指定了Kafka集群中的一个或多个broker的地址。`send()`方法用于向指定的topic发送一条消息，`KafkaConsumer`对象则用于从指定的topic消费消息。