인프런 커뮤니티 질문&답변
작성한 질문수
안녕하세요 Connector 실행 시 오류 질문드립니다.
작성
·
1.3K
0
다음 강의에도 질문을 남겼는데 며칠째 답변이 없어서 다시 질문드립니다....
window 환경에서 실행하고 있고 아래와 같은 오류가 여러개 호출됩니다.
답변 부탁드립니다.
D:\KAFKA_HOME\confluent-6.1.0>.\bin\windows\connect-distributed.bat .\etc\kafka\connect-distributed.properties
[2021-06-14 08:31:22,806] WARN could not get type for name org.easymock.IArgumentMatcher from any class loader (org.reflections.Reflections)
org.reflections.ReflectionsException: could not get type for name org.easymock.IArgumentMatcher
at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:312)
at org.reflections.Reflections.expandSuperTypes(Reflections.java:382)
at org.reflections.Reflections.<init>(Reflections.java:140)
at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader$InternalReflections.<init>(DelegatingClassLoader.java:444)
at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.scanPluginPath(DelegatingClassLoader.java:334)
at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.scanUrlsAndAddPlugins(DelegatingClassLoader.java:268)
at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initPluginLoader(DelegatingClassLoader.java:216)
at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initLoaders(DelegatingClassLoader.java:209)
at org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:61)
at org.apache.kafka.connect.cli.ConnectDistributed.startConnect(ConnectDistributed.java:91)
at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:78)
Caused by: java.lang.ClassNotFoundException: org.easymock.IArgumentMatcher
at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(BuiltinClassLoader.java:581)
at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:178)
at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:521)
at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:310)
... 10 more
답변 5
7
log4j 오류는
connect-distributed.bat의 30번째 줄인
set KAFKA_LOG4J_OPTS=-Dlog4j.configuration=file:%BASE_DIR%/config/connect-log4j.properties
를
set KAFKA_LOG4J_OPTS=-Dlog4j.configuration=file:%BASE_DIR%/etc/kafka/connect-log4j.properties
로 바꾸니 해결됐습니다.
connect-log4j.properties 파일이 위치하는 경로가 잘못 적혀있었습니다.
0
kafka-run-class.bat 해당 파일에서 알려주신 설정 사항에서 jar파일을 읽지 못하는거 같아 오류가 생기는 것 같습니다. 다운받은 confluent-6.1.0 이 아닌 kafka 폴더에서 알려주신 connector 설정 완료 후
connect-distributed.bat 실행 시키니 정상적으로 실행이 되네요 ... ㅜㅜ mariaDB 연결이나 topic등 잘 되는 것 같아 일단은 이렇게 진행 하겠습니다.
0
안녕하세요 답변 감사합니다.
0
안녕하세요, 이도원입니다.
보내주신 Kafka Connect로 실행해 보니, 말씀하신 증상과 유사한 에러가 발생하였습니다. 다운받으신 파일의 문제 또는 압축 해제과정에서 문제가 발생한 것일수도 있을것 같습니다.
0
동일오류 답변주신내용으로 잘 해결하였습니다. 감사합니다.