반응형
1. [kafka] spring boot consumer config 설정, client 입력
2. [kafka] kafka 수동 commit, ENABLE_AUTO_COMMIT_CONFIG
3. [kafka] 실패시 retry, 실패시 처리방법, setRecoveryCallback, setErrorHandler
카프카 기본설정은 생각보다 쉽다.
https://docs.spring.io/spring-kafka/docs/1.0.0.M1/reference/htmlsingle/
https://docs.spring.io/spring-boot/docs/2.1.0.RELEASE/reference/htmlsingle/#boot-features-kafka
이런 문서들 보면된다.
한글 보기쉬운 블로그
내가 필요한건, 컨슈머가 여러가 들어갈수도 있었기에 configuration 을 사용해야 했음. 다른 옵션들도 줄수 있고.
여기에 깔끔하게 다 나온다 . 그대로 하니까 됨
https://memorynotfound.com/spring-kafka-consume-producer-example/
참고
-카프카 리스너의 여러가지 구현 방법
- 설정값, 간단한 설명 도움
반응형
'Web > SpringBoot' 카테고리의 다른 글
[kafka] 실패시 retry, 실패시 처리방법, setRecoveryCallback, setErrorHandler (0) | 2019.12.17 |
---|---|
[kafka] kafka 수동 commit, ENABLE_AUTO_COMMIT_CONFIG (4) | 2019.12.10 |
Configure Pod readiness with Spring Actuator (0) | 2019.11.20 |
[springboot] healthcheck ,actuator, kubernetes 헬스 체크 하여 pod 롤링 업데이트 403 에러 - 2/2 (0) | 2019.11.18 |
Spring Transaction rollback 이 안됨 (1) | 2019.11.08 |
댓글