카프카 연결 합치적인 탄성 검색 싱크 (클래스를 찾을 수 없음 오류)

Question

나는 카프카 연결에 매우 익숙하다. 카프카 주제에서 탄성 검색까지 내 메시지를 보내고 싶습니다. 사용 가능한 문서를 따른 후 .. 릴리스 tar.zip (https://github.com/confluentinc/kafka-connect-elasticsearch/releases)에서 탄성 검색 싱크를 다운로드하고 컴파일했습니다.

탄성 검색 속성 파일을 추가하고 classpath에 위의 jar를 포함 시켰습니다. 내가 독립 모드로 연결 카프카 실행하면 나는

[2016-11-13 00:05:38,768] ERROR Task elasticsearch-sink-0 threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:142) java.lang.NoClassDefFoundError:io/searchbox/client/JestClientFactory 
at io.confluent.connect.elasticsearch.ElasticsearchSinkTask.start(ElasticsearchSinkTask.java:81) 
at io.confluent.connect.elasticsearch.ElasticsearchSinkTask.start(ElasticsearchSinkTask.java:52) 
at org.apache.kafka.connect.runtime.WorkerSinkTask.initializeAndStart(WorkerSinkTask.java:207) 
at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:139) 
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:140) 
at o 

NoClassDefFoundError:io/searchbox/client/JestClientFactory

./usr/bin/connect-standalone etc/schema-registry/connect-avro-standalone.properties etc/kafka-connect-elasticsearch/quickstart-elasticsearch.properties

내가 pom.xml 파일을 checkedthe이 오류를 얻을 수 있으며 올바르게 정의 농담 클라이언트 의존성을 가지고있다. 내가 놓친 게 있니?

모든 포인터는 정말 감사하겠습니다.

덕분에, 인 Rajesh

Answer 1

그것은 클래스 패스에서 누락 된 종속성 중 하나처럼 보인다. Github Releases 페이지의 패키지에는 종속성이 없습니다.

Confluent Open Source distribution을 사용하고 quickstart을 따르는 것이 좋습니다.

Answer 2

지방산 단지도 만들 수 있습니다. , pom으로 카프카의 디렉토리를 LIBS에 종속성이있는 단지를 구축하고 복사 descriptorRefs

<build> 
 
    <plugins> 
 
    .... 
 
    <plugin> 
 
     <groupId>org.apache.maven.plugins</groupId> 
 
     <artifactId>maven-assembly-plugin</artifactId> 
 
     <configuration> 
 
     .... 
 
     <descriptorRefs> 
 
      <descriptorRef>jar-with-dependencies</descriptorRef> 
 
     </descriptorRefs> 
 
     </configuration> 
 
     .... 
 
    </plugin> 
 
    </plugins> 
 
    .... 
 
</build>

를 추가합니다.