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

[yeollow]

Spring Batch Job

Bacth Job 내용은 #18 의 Spring Batch Job내용과 동일

• Police에 관한 Job개발 및 scopeJob에 추가.

Kafka

producer 및 broker설정 내용 또한 #18 의 Kafka내용과 동일

• Police topic 생성 및 각기 다른 topic에 대한 default-topic을 지정 후 전송

[yeollow]

BeanCreationException

../config/kafka/KafkaWriterConfig.java에서 각 topic별 KafkaItemWriter를 지정해준 @Bean이 정상적으로 생성되지 않음.

• 기존의 KafkaTemplate 생성자 DI방식과 Bean Circuler Reference문제를 뱉은 KafkaTemplate지정 방식 두가지를 다시 시도
  • 두가지 지정 방식 중 하나를 채택해야함. 두가지 모두를 작성해놓으면 Template bean이 이미 creation되었다는 BeanCurrentlyIncreationException이 발생함.
• @Bean 생성 실패 이유는, kafkaTemplate에 관한 setDefaultTopic()지정 시 NullPointerException발생.

KafkaTemplate지정 방식

• application-local.yml에 지정한 값들을 @Value로 뽑아와 template지정에 사용.
  • spring kafka연동 시 application.yml에 설정한 값 내용이 자동으로 load되는 듯!

• properties를 Map.ofEntries와 같이 Factory Method Pattern으로 구현.

  @Value(value = "${spring.kafka.producer.bootstrap-servers}")
  private String bootStrapServer;
  
  @Value(value = "${spring.kafka.producer.key-serializer}")
  private String keySerializer;
  
  @Value(value = "${spring.kafka.producer.value-serializer}")
  private String valueSerializer;
  
  @Value(value = "${spring.kafka.producer.acks}")
  private String acks;
  
  @Bean
  public ProducerFactory<Long, ?> producerFactory() {
      Map<String, Object> properties = Map.ofEntries(
          Map.entry(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootStrapServer),
          Map.entry(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, keySerializer),
          Map.entry(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, valueSerializer),
          Map.entry(ProducerConfig.ACKS_CONFIG, acks)
      );
  
      return new DefaultKafkaProducerFactory<>(properties);
  }
  
  @Bean
  public KafkaTemplate<Long, ?> kafkaTemplate() {
      return new KafkaTemplate<>(producerFactory());
  }