我正在尝试为我们的合流云安装MQ源和宿连接器。我已经为本地apache kafka做了这件事,但对云做同样的事情似乎是不同的。根据confluent文档,我需要在本地安装一个平台,然后运行confluent-hub安装,在本地安装连接器,然后使用json for distributed instance。我的问题是,当我运行json时,它说没有找到mq的类,我试图将CLASSPATH指向jars所在的目录,但仍然得到相同的错误。我怎样才能成功地运行它? --
ERROR Uncaught exception in REST call to /connectors (org.apache.ka
我正在使用Couchbase接收器连接器。CB和kafka在两个不同的EC2实例中,在不同的AWS区域。我正在跟踪这些文件:
基于这些,我认为连接必须在安装了kafka的主机上运行。我的连接能否在远程主机上运行,比如我从远程kafka读取消息并将消息接收到远程CB桶中?有这方面的文件吗?
此外,我还收到以下错误:
at org.apache.kafka.connect.util.ConvertingFutureCallback.result(ConvertingFutureCallback.java:79)
at org.apache.kafka.connect.ut
我不知道还能转到哪里去,就像我看到的所有例子一样,我已经复制了很多,但仍然无法让它发挥作用。连接器将不安装并声明为空密码。我已经验证了每一步,不能让它开始工作。以下是我所采取的步骤。
容器
FROM strimzi/kafka:0.16.1-kafka-2.4.0
USER root:root
RUN mkdir -p /opt/kafka/plugins/debezium
COPY ./debezium-connector-mysql/ /opt/kafka/plugins/debezium/
USER 1001
接下来,我创建与mySQL一起使用的秘密。
cat <<EOF |
试图连接到Kafka集群并从一个主题向雪花写入数据。
我得到的错误是:
java.util.concurrent.ExecutionException: org.apache.kafka.connect.errors.ConnectException: Failed to find any class that implements Connector and which name matches com.snowflake.kafka.connector.SnowflakeSinkConnector
available connectors are: PluginDesc{klass=cl