enhancement: #15 [Spring Batch Job] : Kafka local Producer(CCTV / Police) developing2

[yeollow]

19 local Kafka Producer developing에 이어 개발.

수정 및 개발 내용

• packaging
  • topic에 따라 진행될 Batch Job에 대한 작업을 위해 ../config/batchjob아래에 XXXBatchJobConfig로 @configuration 분할
  • Kafka 관련 내용은 ../config/kafka/KafkaWriterConfig로 @configuration 분할
• 수정 내용
  • KafkaWriterConfig에서 KafkaTemplate<Long,?>에 대해 생성자 주입을 통해 KafkaTemplate을 얻음.
    • spring-kafka 관련 properties는 application-local.yml에 설정해놓은 상태이며 Application Context가 실행될 때 load함
  • CCTV, Police 이외에도 여러 topic에 대한 data Entity가 추가될 수 있으므로 각 Entity별 KafkaTemplate<Long,Entity> 등을 통해 지정하지 않고, 동적으로 KafkaTemplate<Long,?>와 같이 와일드카드로 받아 각 topic별 kafkaWriter전달 시 KafkaTemplate<Long,Entity>등과 같이 형변환으로 진행하도록 함
• topic data Entity에 @Builder pattern 제거

[yeollow]

Code Refactoring

../config/batchjob/XXXBatchJobConfig.java 에서 Batch Job처리를 위해 write시 ../config/kafka/KafkaWriterConfig.java 에 정의된 KafkaItemWriter Bean이 필요함.

현재는 KafkaWriterConfig @configuration의 KafkaItemWriter Bean을 갖기 위해 XXXBatchJobConfig @configuration에서 new를 통해 KafkaItemWriter @configuration을 생성하여 KafkaItemWriter @Bean을 다시 @Bean으로 정의하여 KafkaWriterConfig @configuration내부에서 사용하는 형태임.

• Spring은 Bean을 Singleton으로 관리하기 때문에 다시 @Bean으로 생성해준다고 해서 다른 Instance를 갖지는 않으므로 채택
  • new로 KafkaWriterConfig @configuration을 다룰 필요가 없을 것 같음. 내가 원하는건, @configuration내부에 있는 특정한 @Bean (KafkaItemWriter)이므로 XXXBatchJobConfig에서 가져오고 싶은 특정한 @Bean만을 가져오자.

[yeollow]

kafka issue

현재 cctv와 police에 대한 batch job 및 kafkatemplate설정까지 완료. but batch application실행 시 kafka topic CCTV / POLICE중 CCTV와 Police entity data에 대한 내용이 모두 POLICE topic에 들어감..

• consumer관련 properties를 설정하지 않아서 그런가?? 그건 아닌거같은데.. producer할때 topic을 지정하잖아..