我正在尝试使用Kafka Connect Elasticsearch连接器,但没有成功。org.apache.kafka.connect.errors.ConnectException: Failed to find any class that implements Connector and which name matches io.confluent.connect.elasticsearch.ElasticsearchSinkConnectorversion='1.0.1',
我目前正试图在kafka- connector集群(分布式模式)上启动一个elasticsearch接收器连接器,这个集群是在kubernetes中部署的,它使用汇流提供的舵图,并在其中进行了一些调整。困扰我的是,当连接器启动时,没有创建索引,而且在kafka-connect的日志中也没有错误.上面说一切都开始了
Starting connectors and tasks using config