如何将 KafkaAvroSerializer 传递给 Kafka ProducerRecord？答案

【问题标题】：how can I pass KafkaAvroSerializer into a Kafka ProducerRecord?如何将 KafkaAvroSerializer 传递给 Kafka ProducerRecord？
【发布时间】：2019-07-19 23:45:11
【问题描述】：

我有正在流式传输到 Kafka 的消息。我想将消息转换为 avro 二进制格式（意味着对它们进行编码）。我正在使用融合平台。我有一个 Kafka ProducerRecord[String,String]，它将消息发送到 Kafka 主题。有人可以提供一个（简短的）例子吗？或者推荐一个有例子的网站？

有谁知道我如何将KafkaAvroSerializer 的实例传递给KafkaProducer？我可以在 ProducerRecord 中使用 Avro GenericRecord 实例吗？

亲切的问候

尼卡

【问题讨论】：

希望这个小例子能帮助你：gist.github.com/mfirry/f65b16696e567b6edbede1ef9f924a8c
谢谢！我不需要 GenericRecord 来存储值吗？或者如果我集成 KafkaAvroSerializer 就足够了吗？

标签： scala apache-kafka avro confluent-platform

【解决方案1】：

您需要在生产者配置中为任一序列化器配置使用 KafkaAvroSerializer，并在生产者配置中设置架构注册表 url (AbstractKafkaAvroSerDeConfig.SCHEMA_REGISTRY_URL_CONFIG)

该序列化程序将对原语和字符串进行 Avro 编码，但如果您需要复杂的对象，您可以尝试添加 Avro4s，例如。否则，GenericRecord 也可以工作。

Java 示例在这里 - https://docs.confluent.io/current/schema-registry/serializer-formatter.html

【讨论】：