Версия формата сообщений для Коннектора kafka в KUMA 2.1.1.73

[Андрей Лобачев]

Коллеги, добрый день.
Подскажите, пожалуйста, какая версия протокола и какой формат сообщений используется Коннектором kafka в KUMA версии 2.1.1.73?

 

В самой Apache Kafka за это отвечают параметры inter.broker.protocol.version и log.message.format.version.
Первый inter.broker.protocol.version совпадает с версией Kafka, используется "внутри неё".
Второй log.message.format.version используется для обмена с консьюмерами и продьюсерами. 

 

Интересует какое значение выставить для log.message.format.version чтобы KUMA могла без проблем взаимодействовать с кластером Kafka?
Мне известно про обратную совместимость форматов сообщений в Kafka. Стоит задача обеспечить максимальное соответствие версий для оптимизации производительности.

 

В документации https://support.kaspersky.ru/help/KUMA/2.1/ru-RU/217776.htm к сожалению, не нашёл.

И будут ли изменения по версии формата логов в обновлении KUMA 3.0?

 

[Андрей Лобачев]

Возможно ли предположить, что если KUMA написана на Golang, то вероятнее всего были использованы библиотеки, встроенные в язык? Таким образом, для взаимодействия с Kafka используется стандартная Go-библиотека kafka-go  и ответ на вопрос можно искать в описании к ней https://pkg.go.dev/github.com/segmentio/kafka-go#section-readme ?