nx-gs-kafka
Небольшой фасад клиента Kafka для Java 8 и новее: producer и consumers с JSON-сериализацией, отслеживанием состояния соединения и переподключением. Модули адаптера публикуют через него; настройки подключения приходят с платформы при подключении.
Координаты
Заголовок раздела «Координаты»app.l2nx:nx-gs-kafkaJava 8. Тег релиза kafka/vX.Y.Z. Версии — на
maven-oss.
Когда нужен хосту
Заголовок раздела «Когда нужен хосту»Приходит транзитивно с nx-gs-adapter-core; объявлять его не нужно.
Зависит от org.apache.kafka:kafka-clients без нативных библиотек сжатия: чтобы использовать сжатие lz4, snappy
или zstd, добавьте JAR соответствующей библиотеки сами.
Конфигурация
Заголовок раздела «Конфигурация»Настройки producer задаются ключами core l2nx.kafka.producer.*:
конфигурация → nx-gs-adapter-core.