在Kafka中，使用不同的消费者组进行消息消费是非常简单的。如果您想要将一个消费者组中的消费者处理的消息传递给另一个消费者组，可以使用Kafka的重复消费机制。以下是示例代码：

第一组消费者代码

from kafka import KafkaConsumer from kafka import KafkaProducer

创建一个Kafka消费者，消费来自topic ‘my_topic’的消息，一次消费一条消息

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

创建一个Kafka生产者，生产消息到新的topic ‘my_topic_reprocessed’

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

for message in consumer: # 一些处理逻辑 # 重新生产消息到新的topic producer.send('my_topic_reprocessed', message.value)

第二组消费者代码

from kafka import KafkaConsumer from kafka import KafkaProducer

创建一个Kafka消费者，消费来自topic ‘my_topic_reprocessed’的消息

consumer = KafkaConsumer('my_topic_reprocessed', bootstrap_servers=['localhost:9092'], group_id='group_B')

for message in consumer: # 处理来自第一组消费者重新处理后的消息 # ...

这样，第一组消费者将消费消息并将消息重新发送到新的topic，第二组消费者将消费已处理的消息。