ERROR 오류로 인해 중지 중 (org.apache.kafka.connect.cli.ConnectDistributed) java.lang.NoClassDefFoundError : io / debezium / util / IoUtil

jump_monkey

객관적인

Debezium 커넥터 (1.2.4.Final)를 사용하여 Kafka Connect (이상적으로는 분산 모드)에서 Oracle Database (12c)에 연결하려고합니다. 내가 사용하는 Kafka 버전은 2.13-2.6.0입니다.

사용 된 명령

여기언급 된 대로이 명령을 실행하고 있습니다.

C:\Users\username\Downloads\kafka>bin\windows\connect-distributed.bat config\connect-distributed.properties

오류

내가 얻는 오류는 다음과 같습니다.

오류 (org.apache.kafka.connect.cli.ConnectDistributed) java.lang.NoClassDefFoundError : io / debezium / util / IoUtil at io.debezium.connector.oracle.Module. (Module.java:19) org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.versionFor (DelegatingClassLoader.java:390)의 io.debezium.connector.oracle.OracleConnector.version (OracleConnector.java:23) org.apache.kafka.connect. runtime.isolation.DelegatingClassLoader.versionFor (DelegatingClassLoader.java:395) at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.getPluginDesc (DelegatingClassLoader.java:365) at org.apache.kafka.connect.runtime.isolation. org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.scanUrlsAndAddPlugins (DelegatingClassLoader.java:268)의 DelegatingClassLoader.scanPluginPath (DelegatingClassLoader.java:337).org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initPluginLoader (DelegatingClassLoader.java:229)의 kafka.connect.runtime.isolation.DelegatingClassLoader.registerPlugin (DelegatingClassLoader.java:260) at org.apache.kafka.connect. org.apache.kafka.connect.runtime.isolation.Plugins. (Plugins.java:61)의 runtime.isolation.DelegatingClassLoader.initLoaders (DelegatingClassLoader.java:206) at org.apache.kafka.connect.cli.ConnectDistributed.startConnect (ConnectDistributed.java:91) at org.apache.kafka.connect.cli.ConnectDistributed.main (ConnectDistributed.java:78) 원인 : java.lang.ClassNotFoundException : io.debezium.util.IoUtil at java.net.URLClassLoader .findClass (URLClassLoader.java:382) at java.lang.ClassLoader.loadClass (ClassLoader.java:418) at org.apache.kafka.connect.runtime.isolation.PluginClassLoader.loadClass (PluginClassLoader.java : 104) at java.lang.ClassLoader.loadClass (ClassLoader.java:351) ... 13 more

설정

내 connect-distributed.properties에 다음이 있습니다.

plugin.path=C:/Users/username/Downloads/kafka/libs/debezium

그리고 debezium 폴더 ( 이 질문 의 주석에서 Gunnar의 권장 사항에 따라) 안에 다음과 같은 항아리가 있습니다.여기에 이미지 설명 입력

또한 다음과 같이 % PATH %에 플러그인 경로를 추가했습니다.

echo %PATH% | findstr debezium

XXX; C : \ Users \ 사용자 이름 \ Downloads \ kafka \ libs \ debezium;

도움

내 데이터베이스 폴링을 더 나은 접근 방식으로 보이는이 debezium 커넥터로 교체하기를 희망하므로 어떤 도움이라도 대단히 감사하겠습니다. 감사!

jump_monkey

군나르에서이 솔루션은 여기에 작품! (확인하고 싶다면 그의 설명도 있습니다.)

plugin.path=C:\\Users\\username\\Downloads\\kafka\\libs

또한 작동합니다.

plugin.path=C:/Users/username/Downloads/kafka/libs
plugin.path=C:\Users\username\Downloads\kafka\libs
plugin.path=/Users/username/Downloads/kafka/libs

실수는 : plugin.pathlibs / debezium이 아닌 libs에 달려 있어야합니다.

이 기사는 인터넷에서 수집됩니다. 재 인쇄 할 때 출처를 알려주십시오.

침해가 발생한 경우 연락 주시기 바랍니다[email protected] 삭제

에서 수정
0

몇 마디 만하겠습니다

0리뷰
로그인참여 후 검토

관련 기사

Related 관련 기사

뜨겁다태그

보관