java - 配置函数在 Kafka 序列化器/反序列化器中起什么作用？

Question

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

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

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

Answer 1

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

void configure​(java.util.Map<java.lang.String,?> configs,boolean isKey)

Configure this class.

Parameters:configs - configs in key/value pairs, isKey - whether is for key or value

基本上，configure 方法接受配置映射作为其第一个参数，第二个参数为 boolean 值，如果它用于 Key，则设置为 true；如果用于值，则设置为 false。

从那里，这些配置可以存储为反/序列化器实现中的字段，并用作反/序列化方法的一部分。例如，StringSerializer has an encoding property .