我正在使用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
我有一个在Confluent Cloud中运行的集群,并且能够使用其他应用程序生成和使用数据。然而,当我尝试连接Snowflake Kafka连接器时,我收到以下错误:
[2019-10-15 22:12:08,979] INFO Creating connector source-snowflake of type com.snowflake.kafka.connector.SnowflakeSinkConnector (org.apache.kafka.connect.runtime.Worker)
[2019-10-15 22:12:08,983] INFO Instantiated c
我正在尝试使用Kafka Connect Elasticsearch连接器,但没有成功。它正因以下错误而崩溃:
[2018-11-21 14:48:29,096] ERROR Stopping after connector error (org.apache.kafka.connect.cli.ConnectStandalone:108)
java.util.concurrent.ExecutionException: org.apache.kafka.connect.errors.ConnectException: Failed to find any class that impleme