时间戳

首页 > 解决方案 > 用于elasticsearch错误的kafka连接器

elasticsearch - 用于elasticsearch错误的kafka连接器

问题描述

您好，我在为 Kafka 安装弹性搜索连接器时遇到问题。我遵循了本教程： https ://sematext.com/blog/kafka-connect-elasticsearch-how-to/

当我尝试以独立模式启动连接器时的错误是：

(org.apache.kafka.connect.cli.ConnectStandalone:74)
Exception in thread "main" java.lang.NoSuchMethodError: com.google.common.collect.Sets$SetView.iterator()Lcom/google/common/collect/UnmodifiableIterator;
    at org.reflections.Reflections.expandSuperTypes(Reflections.java:380)
    at org.reflections.Reflections.<init>(Reflections.java:126)
    at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.scanPluginPath(DelegatingClassLoader.java:263)
    at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.scanUrlsAndAddPlugins(DelegatingClassLoader.java:206)
    at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initPluginLoader(DelegatingClassLoader.java:154)
    at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initLoaders(DelegatingClassLoader.java:147)
    at org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:47)
    at org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:75)

我使用一个 AWS EC2 小实例来测试这个连接器。

我该如何解决这个错误？

标签： elasticsearchapache-kafkaapache-kafka-connectconfluent-platform

解决方案

推荐阅读