NestJS Kafka

[TorinAsakura]

С чем связан запрос на фичу?

NestJS не имеет встроенной поддержки

Расскажите как вы это себе видите

1. kafkaLogCreator: Создаёт функцию для обработки логов Kafka. Использует Logger для кастомного логирования с уровнями логов (error, warn, info, debug). Может работать с различными пространствами имён (namespace), создавая подлоггер при необходимости.
2. KafkaConfigFactory: Конфигурирует Kafka-клиент, используя либо переданные параметры, либо значения из переменных окружения. Возвращает объект конфигурации для Kafka, включая clientId и список брокеров.
3. KafkaFactory: Использует KafkaConfigFactory для создания экземпляра Kafka с учётом настроек логирования (logCreator). Позволяет передавать дополнительные опции через параметр options.
4. KafkaModule: Предоставляет метод register, позволяющий зарегистрировать модуль с конфигурацией Kafka. Внедряет и экспортирует KafkaConfigFactory и KafkaFactory.

Зачем это нужно?

1. Централизация конфигурации Kafka: Модуль позволяет легко и централизованно управлять конфигурацией и логированием для подключения к Kafka.
2. Гибкая настройка логирования: kafkaLogCreator обеспечивает интеграцию кастомного логирования с использованием kafkajs.
3. NestJS-стиль внедрения зависимостей: Использование DI (Dependency Injection) NestJS для подключения к Kafka, что упрощает поддержку и масштабирование кода.

Материалы

https://docs.nestjs.com/microservices/kafka