kafka传输list

在Kafka中传输列表（List）可以通过将列表转换为字符串进行传输。以下是一个简单的示例：

1. 生产者端：

from kafka import KafkaProducer
import json

# 创建Kafka生产者
producer = KafkaProducer(bootstrap_servers='localhost:9092')

# 要传输的列表
my_list = [1, 2, 3, 4, 5]

# 将列表转换为字符串
list_str = json.dumps(my_list)

# 发送消息
producer.send('my_topic', value=list_str.encode('utf-8'))

2. 消费者端：

from kafka import KafkaConsumer
import json

# 创建Kafka消费者
consumer = KafkaConsumer('my_topic', bootstrap_servers='localhost:9092')

# 接收消息
for msg in consumer:
    # 将接收到的消息转换回列表
    list_str = msg.value.decode('utf-8')
    my_list = json.loads(list_str)
    
    # 处理列表数据
    print(my_list)

在生产者端，我们使用`json.dumps()`将列表转换为字符串，并使用`encode('utf-8')`将其编码为字节流进行传输。在消费者端，我们使用`decode('utf-8')`将字节流解码为字符串，并使用`json.loads()`将字符串转换回列表。

请注意，这只是一种基本的示例，实际的实现可能因应用需求而有所不同。