Что делает функция configure в сериализаторах / десериализаторах Kafka?

Question

Я изучаю возможность реализации пользовательских сериализаторов / десериализаторов для Kafka. Чтобы реализовать пользовательский сериализатор / десериализатор Kafka, мы должны реализовать org.apache.kafka.common.serialization.Serializer и org.apache.kafka.common.serialization.Deserializer соответственно.

Что я не понимаю, так это метод configure(Map configs, boolean key). Что оно делает? Что мы должны передать в это? Какова цель этого?

Большинство примеров, в которые я вошел, не реализовали ничего внутри метода. Но я хочу знать, что именно это делает. Не просто игнорировать это.

Answer 1

Поскольку вы пытаетесь реализовать собственный сериализатор, для настройки сериализатора при запуске будет использоваться метод configure. Если вы хотите узнать больше о методе настройки, просим go по этой ссылке: https://kafka.apache.org/20/javadoc/org/apache/kafka/common/serialization/Serializer.html

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

Настроить этот класс.

Параметры: config - конфиги в парах ключ / значение, isKey - для ключа или значения

По сути, конфигурация Метод принимает карту конфигураций в качестве первого аргумента, а второй аргумент - логическое значение, которое устанавливает значение true, если оно для ключа, или значение false, если это значение.