#apache-kafka #ibm-mq #confluent-cloud
Вопрос:
Я пытаюсь установить разъемы MQ source amp; sink для нашего облака confluent. Я сделал это для предварительной установки apache kafka, но делать то же самое с облаком, похоже, по-другому. В следующих документах confluent говорится, что мне нужно установить платформу на моем локальном компьютере, что я и сделал, а затем запустить установку confluent-концентратора, которая устанавливает соединитель на моем локальном компьютере, а затем использует json для распределенного экземпляра. Моя проблема в том, что когда я запускаю json, в нем говорится, что класс для mq не найден, я попытался указать ПУТЬ к классу в директорию, где находятся банки, но все равно получаю ту же ошибку. Как мне успешно выполнить это?
--
ERROR Uncaught exception in REST call to /connectors (org.apache.kafka.connect.runtime.rest.errors.ConnectExceptionMapper:61)
org.apache.kafka.connect.errors.ConnectException: Failed to find any class that implements Connector and which name matches io.confluent.connect.ibm.mq.IbmMQSourceConnector,
Также хотите понять, как установка коннектора на локальном компьютере будет применяться к моему облачному кластеру? Не знаю, чего мне не хватает!
Ответ №1:
В последний раз, когда я проверял, Confluent Cloud не поддерживает установку пользовательских соединителей. Они должны явно поддерживать и предлагать это.
Я предполагаю, что вы читаете некоторую документацию, в которой указано, что вам нужно запустить свой собственный кластер подключения (не обязательно локально), где у вас есть полный контроль над установленными соединителями
Комментарии:
1. Это разработанный confluent разъем «Kafka Connect IBM MQ Source», в их документе показано, что я должен установить его с помощью confluent-hub, а затем подключиться к экземпляру платформы. Нельзя ли это сделать, если они явно не назначат нам этот соединитель?
2. «Разработанный» не означает «предлагаемый Confluent Cloud». Так что нет, все эти инструкции предназначены для ваших собственных экземпляров установки Kafka Connect, т. Е. Confluent самостоятельно выполнит эти команды в кластере Confluent Cloud для всех клиентов, использующих его