请使用confluent_kafka，给我一份多线程生产者和消费者的python3代码

下面是一个使用`confluent_kafka`实现多线程生产者和消费者的Python3代码示例：

from confluent_kafka import Producer, Consumer
import threading
import time


class KafkaProducer(threading.Thread):
    def __init__(self, topic, conf):
        threading.Thread.__init__(self)
        self.topic = topic
        self.producer = Producer(conf)

    def run(self):
        num = 0
        while True:
            message = 'Message {}'.format(num)
            self.producer.produce(self.topic, message.encode('utf-8'))
            num += 1
            time.sleep(1)


class KafkaConsumer(threading.Thread):
    def __init__(self, topic, conf):
        threading.Thread.__init__(self)
        self.topic = topic
        self.consumer = Consumer(conf)
        self.consumer.subscribe([self.topic])

    def run(self):
        while True:
            msg = self.consumer.poll(1.0)
            if msg is None:
                continue
            if msg.error():
                print("Consumer error: {}".format(msg.error()))
                continue
            print('Received message: {}'.format(msg.value().decode('utf-8')))


conf = {
    'bootstrap.servers': 'localhost:9092',
    'group.id': 'mygroup',
    'session.timeout.ms': 6000,
    'auto.offset.reset': 'earliest'
}

producer = KafkaProducer('mytopic', conf)
consumer = KafkaConsumer('mytopic', conf)

producer.start()
consumer.start()

producer.join()
consumer.join()

在这个示例中，我们创建了一个`KafkaProducer`类和一个`KafkaConsumer`类，这两个类都继承了`threading.Thread`类，以实现多线程。在`KafkaProducer`类中，我们使用`Producer`类实现生产者逻辑，在`KafkaConsumer`类中，我们使用`Consumer`类实现消费者逻辑。

在主程序中，我们创建了一个`KafkaProducer`对象和一个`KafkaConsumer`对象，并启动它们的线程。然后，使用`join()`方法等待线程运行结束。

注意：在使用这个示例代码前，需要先安装`confluent_kafka`库并启动Kafka服务。