我试图安装Elasticsearch连接器汇合卡夫卡连接。我遵循以下指示:
执行后:
confluent-hub install confluentinc/kafka-connect-elasticsearch:latest
一切看起来都很好。见下文结果:
[ec2-user@ip-172-31-16-76 confluent-6.1.0]$ confluent-hub install confluentinc/kafka-connect-elasticsearch:latest
The component can be installed in any of the following Co
我把我的数据从卡夫卡主题流到elasticsearch。但是它从连接器{\"type\":\"illegal_argument_exception\",\"reason\":\"object mapping [search_data] can't be changed from nested to non-nested\"}抛出了这个错误
但是,当我从主题获取消息并使用elasticsearch手动添加文档时,它运行得很好。
kafka-connect elasticsearch不支持嵌套对象类型吗?
请帮我回答这个问题,
我正在尝试使用mongo get data from mongoDB to my kafka topic db (作为源),elasticsearch (作为接收器)和kafka构建一条数据管道。我已经成功地从mongoDB收到了我的kafka主题的数据。这是从mongoDB捕获的数据示例
{"_id": {"_data": "825E88FED8000000012B022C0100296E5A10044D2CA180FAF94580B30CFA4B3CC80E1546645F696400645E88FED793AFA61A58411B2A0004
我想在confluent上使用JDBC连接器。当我开始与合流CLI连接时,它就不起作用了。
confluent local start connect
它给出了这样的错误:
Caused by: java.sql.SQLException: No suitable driver found for jdbc:oracle:thin:@10.10.10.10:1954/MYSERVICE
我停止连接并手动启动connect-distributed或独立,这会产生相同的错误
./bin/connect-distributed etc/schema-registry/connect-avro-di