inflearn logo
강의

Course

Instructor

[Apache Kafka Application Programming] From concepts to consumers, producers, connects, and streams!

KStream, KTable Join Streams Application

KStreamJoinKTable 실행시 오류

74

dldbwls1123

7 asked

0

맥북 M1이고 jdk version "1.8.0_402" 입니다.

KStreamJoinKTable 실행시 오류가 나서 order_join 결과값에 아무것도 나오지 않습니다.

 

스크린샷 2025-06-17 오후 6.03.12.png.webp

 

kafka 데이터-엔지니어링

Answer 2

0

dvwy

안녕하세요.

보내주신 로그에 따르면 정확한 원인을 찾기 어렵습니다.

  • 사용된 자바 코드

  • build.gradle

  • 로그 전체

  • 실행시 사용한 JDK 버전

을 공유해주시면 다시 한번 확인 후 답변드리겠습니다~

0

dldbwls1123

코드와 build.gradle은 강사님이 주신 코드로 했고 jdk 버전은 글에 명시해놓았습니다.

0

dvwy

보여주신 현상을 확인했을 때, rocksdb의 호환 jdk 버전이 맞지 않아 생긴 이슈로 추정됩니다.

jdk를 11로 업그레이드해서 재실행해보시겠어요? 만약에 안된다면, 에러 로그전체를 보내주시면 다시 확인해보겠습니다.

0

communityai8509

안녕하세요, 인프런 AI 인턴입니다.

이유진님께서 겪고 계신 UnsatisfiedLinkError는 네이티브 라이브러리를 로드할 수 없을 때 주로 발생하는 오류입니다. 특히, M1 칩을 사용하는 맥북에서 자주 보고되는 문제로, Kafka Streams와 관련된 RocksDB 라이브러리의 호환성 이슈가 발생할 수 있습니다. 이 문제를 해결하기 위해 몇 가지 방법을 제안드립니다:

  1. RocksDB 및 Kafka Streams 버전 확인:

    • M1 칩에서 사용할 때는 RocksDB의 버전이 6.29.4.1 이상이어야 합니다. Kafka Streams의 경우, 최신 버전을 사용하여 RocksDB와 호환성을 확보할 수 있습니다.
    • 종종 kafka-streams 라이브러리를 3.2.0 이상의 버전으로 올리면 호환성 문제를 해결할 수 있습니다. 예를 들어, Gradle을 사용하는 경우 다음과 같이 설정 파일을 업데이트할 수 있습니다:
      
      implementation 'org.apache.kafka:kafka-streams:3.2.0'
      

  2. JDK 버전 확인 및 업데이트:

    • JDK 버전이 중요하지 않지만, 최신의 안정적인 JDK를 사용하는 것을 추천합니다. M1 맥북에서의 호환성을 높이기 위해 package managers (예: SDKMAN! 또는 Homebrew)를 사용하여 JDK를 관리할 수 있습니다.

아래 게시물에서 추가적인 정보를 확인할 수 있습니다:
- KStream, KTable 조인 스트림즈 애플리케이션에서 에러가 발생하고 있습니다.

위의 정보를 기반으로 오류를 해결하시기를 바랍니다. 그래도 문제가 지속된다면, 추가적인 설정 변경이 필요할 수도 또는 환경에 따라 달리 적용되어야 할 부분이 있을 수 있습니다.

저는 질문자님의 이해를 돕고자 지식공유자님의 기존 답변을 참고하여 유사한 답변 링크를 추천해드리고 있습니다.
현재 베타 기능으로 답변이 만족스럽지 않을 수 있는 점 양해 부탁드립니다. 🙏
추가적으로 궁금한 점이 있으시면, 이어서 질문해 주세요. 곧 지식공유자께서 답변해 주실 것입니다.

consume 이후 lag가 줄어들지 않음

0

71

2

안녕하세요. 강의의 카프카 버전과 현재 시점의 카프카의 차이점 문의 드립니다.

0

102

2

멱등성 프로듀서 retries 관련 질문입니다.

0

95

2

채팅 서비스 개발 시 주의점이 있을까요?

0

95

2

충분히 큰 파티션 생성시 궁금증이 존재합니다.

0

83

2

KTable 키가 없는 레코드 처리

0

70

2

컨슈머 테스트 코드 작성

0

92

2

리밸런스 onPartitionRevoked이 필요한 상황

0

72

2

카프카 클러스터에서 감당 가능한 파티션(레플리카) 수 문의

0

117

2

reset offset 질문

0

73

2

auto.commit.interval.ms 옵션 관련 질문 드립니다.

0

137

2

파티션, 컨슈머 그룹, 컨슈머 관련 질문

0

116

1

java, kotlin

0

126

2

shutdownThread 에 대한 문의 입니다.

0

151

2

zookeeper실행시 오류가 발생합니다.

0

265

2

커스텀 소스 커넥터에서 Thread.sleep (1000) 은 왜 하는거에요?

0

149

2

처리량을 늘리기 위해서 파티션을 늘리고 컨슈머를 늘려야한다고 설명하셨는데요

0

178

3

파티션 개수와 컨슈머 개수의 처리량 관련 질문

0

162

2

동영상 및 이미지 처리 관련 문의 드립니다.

0

221

2

주키퍼 없이 사용 문의 드립니다.

0

297

1

kafka 를 띄우니 오류가 발생하고 종료합니다.

0

278

3

zookeeper 실행시 오류 .. 무엇을 해야 할까요?

0

217

2

파티션 추가로 해결할 수 있지만 늘어난 파티션은 줄일 수 없지 않나요?

0

192

2

카프카 2.8.2 버전과 많이 차이가 있을까요??.

0

161

2