我有一个简单的JSON对象,如下所示
d = { 'tag ': 'blah',
'name' : 'sam',
'score':
{'row1': 100,
'row2': 200
}
}
下面是我的python代码,它向Kafka发送消息
from kafka import SimpleProducer, KafkaClient
import json
# To send messages synchronously
kafka = KafkaClient('10.20.30.12:9092')
producer = SimpleProducer(kafka)
jd = json.dumps(d)
producer.send_messages(b'message1',jd)
我在风暴日志中看到消息正在被接收,但它正在抛出 元组{json structure in here}的转换为空 不知道需要做什么才能解决这个问题?。。
卡夫卡期望值以字节为单位
这是我简单的卡夫卡制作人,它将消息发送到卡夫卡服务器。
这里json.dumps()将json转换为字符串,encode('utf-8')将字符串转换为字节数组。
下面是我给卡夫卡的制作人的代码。我唯一不同的做法是使用
yaml.safe_load
加载json内容。它将内容作为字符串而不是unicode返回。以下是片段在这里,每一行都是存储在文件中的json数据。
相关问题 更多 >
编程相关推荐