我正在尝试部署confluent Kafka连接到elasticsearch。我的弹性堆栈部署在kubernetes上,具有HTTP加密和身份验证。Caused by: org.apache.kafka.connect.runtime.rest.errors.BadRequestException: Connector configurationis invalid and contains the following 3 error(s):
Could not con
我正在尝试创建一个到弹性云的接收器连接器。这是我的Elasticsearch接收器连接器的配置(使用ksqldb)。at org.apache.kafka.connect.runtime.WorkerSinkTask.pollConsumer(WorkerSinkTask.java:451)
at org.apache.kafka.connect.runtime.WorkerSinkTask.pollat org.apache.
我有S3连接Sink和Elastic,它们都被配置为从同一个主题读取数据,并且都分配了不同的使用者组。据我所知,两者应该有相同的数据读入。但是我们所观察到的是,读取到Elastic接收器的数据比保存到S3接收器的数据要少得多。通过简单的检查,我可以发现,虽然S3包含100%的数据是针对这个主题的,但弹性只有10%的数据。安装程序Confluent S3 version :- 5.5.1配置,我有弹
我试图在分布式模式下启动Kafka连接,即使是独立的,我也无法继续下去。这是我的弹性搜索水槽属性connector.class=io.confluent.connect.elasticsearch.ElasticsearchSinkConnectorconnect-configs我正在EC2上运行这个程序,并使用MSK作为Kafka。: Failed t