有没有办法在python中使用多进程来读取kafka主题中的大量消息？

from kafka import KafkaConsumer
from multiprocessing import Process

def consume_topic(topic):
    consumer = KafkaConsumer(topic, bootstrap_servers='your_kafka_servers')
    for message in consumer:
        # 处理消息的逻辑
        print(message.value)

if __name__ == '__main__':
    # 定义要消费的Kafka主题列表
    topics = ['topic1', 'topic2', 'topic3']

    # 创建多个进程来消费Kafka消息
    processes = []
    for topic in topics:
        p = Process(target=consume_topic, args=(topic,))
        p.start()
        processes.append(p)

    # 等待所有进程结束
    for p in processes:
        p.join()