擅长:python、mysql、java
<p><code>AvroProducer</code>假设键和值都是用模式注册表编码的,在键和值的有效负载前面加上一个魔术字节和模式id</p>
<p>如果要对密钥使用自定义序列化,可以使用<code>Producer</code>而不是<code>AvroProducer</code>。但是序列化键(使用您想要的任何格式)和值(这意味着对值进行编码并在magic字节和模式id之前加上前缀)是您的责任。要了解这是如何做到的,您可以查看<code>AvroProducer</code>代码</p>
<p>但这也意味着您必须编写自己的<code>AvroConsumer</code>,并且不能使用<code>kafka-avro-console-consumer</code></p>