Kafka 序列化器/反序列化器中的配置函数有什么作用？答案

【问题标题】：What does configure function do in Kafka serializers / deserializers?Kafka 序列化器/反序列化器中的配置函数有什么作用？
【发布时间】：2020-01-31 06:32:47
【问题描述】：

我正在研究为 Kafka 实现自定义序列化器/反序列化器。要实现一个Kafka自定义的序列化器/反序列化器，我们必须分别实现org.apache.kafka.common.serialization.Serializer和org.apache.kafka.common.serialization.Deserializer。

我不明白的是configure(Map configs, boolean key) 方法。它有什么作用？我们应该传入什么？这样做的目的是什么？

我遇到的大多数示例都没有在方法内部实现任何东西。但我想知道这到底是做什么的。不只是忽略它。

【问题讨论】：

如果您查看 String 序列化器或 Confluent Avro 序列化器的源代码，它们是可配置的
@cricket_007 谢谢。我会调查这些。

标签： java serialization apache-kafka deserialization kafka-serializer

【解决方案1】：

当您尝试实现自定义序列化程序时，configure 方法将用于在开始时配置序列化程序。如果您想了解更多有关配置方法的信息，请通过此链接：https://kafka.apache.org/20/javadoc/org/apache/kafka/common/serialization/Serializer.html

void 配置（java.util.Map 配置， boolean isKey)

配置这个类。

参数： configs - 键/值对中的配置，isKey - 是键还是值

基本上，configure 方法接受 Configurations Map 作为它的第一个参数，第二个参数是一个布尔值，如果它是一个 Key 则设置为 true，如果是值则设置为 false。

【讨论】：