温馨提示:本文翻译自stackoverflow.com,查看原文请点击:java - What does configure function do in Kafka serializers / deserializers?
apache-kafka java serialization deserialization kafka-serializer

java - 在Kafka序列化器/解串器中,配置功能有什么作用?

发布于 2020-03-27 15:41:01

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

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

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

查看更多

查看更多

提问者
ThisaruG
被浏览
109
Fatema Sagar 2020-01-31 16:06

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

void configure(java.util.Map configs,boolean isKey)

配置此类。

参数:configs-键/值对中的配置,isKey-是键还是值

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