카프카 & 플럼

root.logger를 debug로 바꾸니 아래와 같은 에러가 발생했다.에러를 따라가다보니 kafkaSource.class에서 log level이 debug일때만 실행되는 소스가 있는데incrementKafkaEmptyCount를 할때 를 하는데, increment시에

0. 카프카 실행 1. 카프카 토픽 생성 2. 토픽 확인 3. 컨슈머 콘솔에서 토픽 읽기

이렇게 해놔도 latest가 아닌 earlist부터 가져옴. group명을 지정하면 startOffset이 earlist로 세팅됨.그래서 그간 쌓인 몇십만개를 다 읽어오려고함.. @.@https://cloud.spring.io/spring-cloud-strea

kafka 설정에 log.retention을 줄이고 한대씩 재기동log.retention.hours=1 log.retention.ms=1000