Установите пользовательский соединитель для Kafka Connect в Kubernetes

Question

Я запускаю развертывание kafka kubenetes helm, однако я не уверен в том, как установить пользовательский плагин.

При запуске пользовательского плагина в моей локальной версии kafka я монтирую том /myplugin в образ Docker, а затем устанавливаю переменную окружения пути плагина.

Я не уверен, как применить этот рабочий процесс к развертыванию рулевых диаграмм / kubernetes, в основном, как подключить плагин к модулю Kafka Connect так, чтобы его можно было найти по умолчанию plugin.path=/usr/share/java.

Answer 1

Посмотрите на последние несколько слайдов https://talks.rmoff.net/QZ5nsS/from-zero-to-hero-with-kafka-connect.. Вы можете смонтировать свои плагины, но лучший способ - создать новый образ для расширения cp-kafka-connect-base или установить плагин во время выполнения - оба используя Confluent Hub.