擅长:python、mysql、java
<p>卡夫卡期望值以字节为单位</p>
<pre><code>b`some json message`
</code></pre>
<p>这是我简单的卡夫卡制作人,它将消息发送到卡夫卡服务器。</p>
<pre><code>import json
from bson import json_util
from kafka import KafkaProducer
producer = KafkaProducer(bootstrap_servers='localhost:9092')
for i in range(10):
data = { 'tag ': 'blah',
'name' : 'sam',
'index' : i,
'score':
{'row1': 100,
'row2': 200
}
}
producer.send('orders', json.dumps(d, default=json_util.default).encode('utf-8'))
</code></pre>
<p>这里json.dumps()将json转换为字符串,encode('utf-8')将字符串转换为字节数组。</p>