解决kafka connect 启动报错 java.lang.NoSuchMethodError: com.google.common.collect.Sets$SetView.iterator()

报错

./bin/connect-distributed.sh ./config/connect-distributed.properties

./bin/connect-standalone.sh ./bin/connect-standalone.sh  ./config/connect-file-source.properties  ./config/connect-file-sink.properties

[2018-11-23 12:40:21,101] ERROR Stopping due to error (org.apache.kafka.connect.cli.ConnectDistributed:117)
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$InternalReflections.<init>(DelegatingClassLoader.java:410)
at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.scanPluginPath(DelegatingClassLoader.java:310)
at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.scanUrlsAndAddPlugins(DelegatingClassLoader.java:244)
at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initPluginLoader(DelegatingClassLoader.java:192)
at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initLoaders(DelegatingClassLoader.java:185)
at org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:61)
at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:74)

解决

根本原因是CLASSPATH中首先找到的guava版本比较低。

直接原因是本机上之前配过了hadoop 环境，首先找到的是hadoop classpath 中包含有比较低版本的guava jar包，从而找到的不是kafka libs下自带的guava，如果手动一个一个地去把hadoop classpath中的guava去掉 或者换成高版本的(guava-20.0.jar以上)，然后还会报java.lang.NoSuchMethodError: javax.ws.rs.core.Application.getProperties() 等错误，也是一样的原因，hadoop classpath中相关的包版本过低，还得一个有一个去解决。

一步到位的方法是，unzet CLASSPATH ， 注意这样做之后，如果要搭建其他组件的时候 CLASSPATH 记得需要再配一下。