Warm tip: This article is reproduced from stackoverflow.com, please click
apache-kafka java serialization deserialization kafka-serializer

What does configure function do in Kafka serializers / deserializers?

发布于 2020-03-27 15:39:27

I am looking into implementing custom Serializers / Deserializers for Kafka. To implement a Kafka custom Serializer / Deserializer, we have to implement org.apache.kafka.common.serialization.Serializer and org.apache.kafka.common.serialization.Deserializer respectively.

What I don't understand is the configure(Map configs, boolean key) method. What does it do? What should we pass into it? What is the purpose of this?

Most of the examples I came into, have not implemented anything inside the method. But I want to know what exactly this does. Not just ignore it.

Questioner
ThisaruG
Viewed
56
分享
Fatema Sagar 2020-01-31 16:06

As you are trying to implement a custom serializer, the configure method will be used to configure the serializer at the start. If you want to read more about the configure method kindly go through this link: https://kafka.apache.org/20/javadoc/org/apache/kafka/common/serialization/Serializer.html

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

Configure this class.

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

Basically, the configure method accepts the Configurations Map as its first argument and second argument a boolean value, which sets true if it is for a Key or false if it is for value.

ThisaruG 2020-01-31 21:59:20

Thank you for the explanation.

Fatema Sagar 2020-02-03 14:08:53

I hope it was helpful to u.

Related issues

1
Alternative approach for checking data types to build an object
2
Is it possible to get first and last name from Google Authentication on Firebase?
3
Constructor that receives TXT files to read and store them
4
Logback with Elastic Beanstalk
5
Camel Predicate Example in xml DSL
6
How do I get user input validation into my java calculator program?
7
firebase getting exact childs from database
8
Listener for custom dialog null
9
JFrame very small
10
AWS Elastic Beanstalk Application Logging with Logback