给我写一个kafka生产者代码，读取txt文件，以json格式发送到kafka集群

当然，我可以为您提供一些Kafka生产者代码的示例，如下所示：

from kafka import KafkaProducer
import json

producer = KafkaProducer(bootstrap_servers=['localhost:9092'],
                         value_serializer=lambda x: 
                         json.dumps(x).encode('utf-8'))

with open('example.txt', 'r') as file:
    for line in file:
        data = {'message': line.strip()}
        producer.send('test_topic', value=data)

producer.close()

需要注意的是，以上代码只是一个示例，您需要根据自己的情况进行修改和调整，例如更改`bootstrap_servers`的值以与您的Kafka集群连接。还要注意，以上代码假设每行文本只有一个消息，并将每行文本作为一个独立的消息发送到Kafka集群中。如果您的文本包含多个消息，则需要进行额外的处理。