Подключение Kafka-telemetry-interceptor к Kafka Producer поставщика/ Kafka Consumer потребителя#

Опционально библиотеку kafka-telemetry-interceptor можно подключить к клиентам поставщиков и потребителей событий.

Настройка Kafka Producer поставщика#

Для настройки Kafka Producer поставщика необходимо выполнить следующие шаги:

  1. Добавить актуальную версию перехватчика в зависимости проекта.

  2. Добавить настройки перехватчика к настройкам Kafka Producer.

Настройки перехватчика:

Обязательные настройки:

# 1) Подключить интерсептор
interceptor.classes = ru.sbt.ss.kafka.interceptors.telemetry.ProducerTelemetryInterceptor

# 2) Настроить путь к файлу конфигурации телеметрии
interceptor.telemetry.config.path = config/telemetry.json

Необязательные настройки:

# 3) Настроить имена заголовков сообщений, в которых могут лежать идентификаторы сообщений
interceptor.telemetry.message.id.headers = header_name1, header_name2

# 4) Настроить имена заголовков сообщений, по которым будут выведены значения заголовков в атрибуты спанов
interceptor.telemetry.headers = header_name1, header_name2

Настройка Kafka Consumer потребителя#

Для настройки Kafka Consumer потребителя необходимо выполнить следующие шаги:

  1. Добавить актуальную версию перехватчика в зависимости проекта.

  2. Добавить настройки перехватчика к настройкам Kafka Consumer.

Настройки перехватчика:

Обязательные настройки:

# 1) Подключить интерсептор
interceptor.classes = ru.sbt.ss.kafka.interceptors.telemetry.ConsumerTelemetryInterceptor

# 2) Настроить путь к файлу конфигурации телеметрии
interceptor.telemetry.config.path = config/telemetry.json

Необязательные настройки:

# 3) Настроить имена заголовков сообщений, в которых могут лежать идентификаторы сообщений
interceptor.telemetry.message.id.headers = header_name1, header_name2

# 4) Настроить имена заголовков сообщений, по которым будут выведены значения заголовков в атрибуты спанов
interceptor.telemetry.headers = header_name1, header_name2