inflearn logo
강의

강의

N
챌린지

챌린지

멘토링

멘토링

N
클립

클립

로드맵

로드맵

지식공유

카프카 완벽 가이드 - 코어편

텍스트 추가시 메시지 전송하는 Producer 및 FileToDBConsumer의 통합 구동 테스트

OrderDBHandler 에서 데이터가 다 안들어가고 누락이 됩니다.

375

jwleesh

작성한 질문수 2

2

원인을 찾아보니

insertOrders 메소드에서

pstmt.executeUpdate();

이 부분이 문제입니다.

대신에

pstmt.executeBatch();

이렇게 하니

누락된 데이터가 없이

다 들어갑니다.

 

 

 

kafka 데이터-엔지니어링

답변 4

2

educrinity2

executeUpdate() 를 executeBatch() 로 바꾸니 정상 동작하여 1000개 모두 DB에 insert 됩니다. 감사합니다.

1

최은혁

저도 누락이 생겨서 확인해보니 excuteUpdate가 문제였습니다.

postgresql 대신 mariaDB를 사용해서 그런건지는 모르겠지만.

executeBatch를 사용하니 잘 들어가지네요.

https://mkyong.com/jdbc/jdbc-preparedstatement-example-batch-update/

0

jwleesh

무조건 누락이 생기길래 혹시나 프로듀서에서 누락된게

있나 봤더니 아니었고, 컨슈머에서도 누락이 된거는

아니었습니다.

그래서 DB에 등록할때 누락이 된거를 찾았구요

여러번 DROP 도 해보고 하면서 테스트를 해봤었습니다.

 

PreparedStatement 에서

executeUpdate() 는 단일 업데이트에 사용되고,

executeBatch() 는 배치로 추가된 여러 명령을 실행하는 데

적합하다고 알고 있습니다.

그래서 그런거 같습니다.

 

jdbc 도 저는 현재 최신버전인

org.postgresql:postgresql:42.7.3 버전을 사용하고 있는데요

혹시나 그래서 차이가 있는건가 싶습니다.

0

권 철민

잘 알겠습니다.

일단 저도 해당 버전으로 다시 테스트 해볼께요

0

권 철민

안녕하십니까,

음, 좋은 정보 감사합니다. 근데 저는 기존 코드로 별 문제없이 잘 수행이 됩니다.. 기존 데이터를 다 DB에서 DROP 해보시고 다시 해보시면 어떨까 싶습니다.

감사합니다.

virtual box 설치 문제

0

57

2

카프카 서버 구축 관련 문의

0

61

2

카프카 토픽 Key 타입 변경에 관한 질문

0

65

2

Zookeeper에서 KRaft

0

75

1

카프카 학습과 관련하여 질문 드립니다

0

95

2

파티션 증가시 비용 증가 고려

0

66

2

Kafka 초기 Partition 개수 설정 관련 질문

0

80

2

VM 과 도커의 차이

0

135

2

vm 어댑터설정 문의

0

73

2

Cooperative Sticky Rebalancing 질문

0

55

2

consumer 설정 질문

0

65

2

consumer.poll 질문입니다.

1

66

2

mainThread.join() 관련 질문

0

54

2

문의

0

149

2

멀티 브로커 설정 중 포트 충돌 발생

0

118

2

Consumer Group 강의 Lag 질문있습니다!

0

104

2

강의 설명 및 코드 정리

0

171

2

실습 코드는 어디서 받나요.. 아무리 찾아도 엄네요..

0

147

1

java.nio.BufferUnderflowException 에러 발생합니다..

0

153

3

KafkaTimeoutError:

0

155

2

acks 1 이면 비동기가 아니지 않나요?!

0

182

2

Producer의 메시지 비동기화 전송 구현 강좌 내용 중 질문

0

105

2

자문자답: 데이터 누락된다고 하시는 분 참고하세요.

0

214

2

자문자답: kafka Error connecting to node utuntu-20.myguest.virtualbox.org:9092

0

196

2