小编Chr*_*s X的帖子

我有一些列表想通过卡夫卡生产者发送。

listA [1,2,3]
listB ["cat", "dog", "fish"]

生产者以字节形式发送消息，因此我不确定如何正确设置消息，以便在需要引号来发送消息时发送列表。这就是我目前所拥有的。

producer = KafkaProducer(bootstrap_servers='localhost:9092')
for _ in range(1):
        print(producer.send('test', b'"worker_id": listA ,  "worker_name" : listB'))

这个方法只是给我一个语法错误。我也尝试过下面的方法，得到了类似的结果

print(producer.send('test', b("worker_uuid": worker_uuid))