로딩
요청 처리 중입니다...

[KAKFA] 트랜잭션

 [KAKFA] 트랜잭션

개요 카프카에서도 트랜잭션을 적용할 수 있다. 여러 토픽에 메시지를 보낼 때 원자성을 적용해서 모든 메시지를 보내는 게 성공하거나 하나라도 메시지 보내는 게 실패하면 모두 다 실패하게 만들 수 있다.

Producer 설정 @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_SERIALIZER_CLASS_CONFIG, JsonSerializer.class); properties.p...

# kafka # 트랜잭션

원문 링크 : [KAKFA] 트랜잭션