| 일 | 월 | 화 | 수 | 목 | 금 | 토 |
|---|---|---|---|---|---|---|
| 1 | 2 | 3 | 4 | 5 | ||
| 6 | 7 | 8 | 9 | 10 | 11 | 12 |
| 13 | 14 | 15 | 16 | 17 | 18 | 19 |
| 20 | 21 | 22 | 23 | 24 | 25 | 26 |
| 27 | 28 | 29 | 30 |
- 기술블로그
- 백준
- 코딩테스트
- 시스템프로그래밍
- 한이음
- java
- github
- kafka
- 회고록
- testcode
- 협업도구
- 트러블슈팅
- 코테
- AWS
- codingtest
- git
- SpringSecurity
- IT
- kafkaconsumer
- jwt
- 알고리즘
- 자바
- 기록
- Django
- 문자열함수
- 자료구조
- 선택정렬
- 공부기록
- c
- 문자열압축
- Today
- Total
목록kafkaconsumer (2)
신뇽이 되어보자
FileToDBConsumer : Consumer객체를 생성하고 토픽의 데이터를 가져온다.LecturesDBHandler : 가져온 데이터를 DB에 저장한다. (JPA를 사용하였다.) 일단 db에 넣으려면 topic에서 데이터를 가져와야하므로이전 글에서 Controller에서 스레드2개를 사용했다고 했는데,startKafkaConsumer() 를 호출하며 하나의 스레드를 사용했다고 했었다. 이 메서드에서kafkaTopicConfig 에서 토픽 이름 가져오고,kafkaConsumerConfig 에서 카프카 기본 설정들 가져온 후LecturesDBHandler 객체 생성 → FileToDBConsumer 객체 생성 후 FileToDBConsumer의 startConsuming 메서드 호출한다고 이전 글에서 ..
FileToDBConsumer : Consumer객체를 생성하고 토픽의 데이터를 가져온다.LecturesDBHandler : 가져온 데이터를 DB에 저장한다. (JPA를 사용하였다.) 일단 db에 넣으려면 topic에서 데이터를 가져와야하므로이전 글에서 Controller에서 스레드2개를 사용했다고 했는데,startKafkaConsumer() 를 호출하며 하나의 스레드를 사용했다고 했었다. 이 메서드에서kafkaTopicConfig 에서 토픽 이름 가져오고,kafkaConsumerConfig 에서 카프카 기본 설정들 가져온 후LecturesDBHandler 객체 생성 → FileToDBConsumer 객체 생성 후 FileToDBConsumer의 startConsuming 메서드 호출한다고 이전 글에서 ..