[KAFKA] DB, KAFKA Transaction

개요 카프카에 메시지를 보내는 과정에 DB에 write 하는 과정을 하나의 트랜잭션으로 묶을 수 있다. 하나의 트랜잭션으로 묶게 되면 진행 과정에서 예외가 발생했을 때 카프카에 메시지를 보내는 과정과 DB에 write 하는 과정을 한 번에 rollback 할 수 있다.

Producer, Consumer Config 설정값 @Bean public ProducerFactory producerFactory() { final Map properties = new HashMap(); properties.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092"); properties.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class); properties.put(ProducerConfig.VALUE_SER...