• Spring Kafka Transaction

    Spring Kafka Transaction Spring Kafka Transaction과 관련된 라이브러리를 정리한 글이다. 더 자세한 내용은 레퍼런스를 참고하길 바란다. Spring for Apache Kafka adds transaction supoort in several ways KafkaTransactionManager Transactional KafkaMessageListenerContainer Local Transaction with KafkaTemplate Transactions Transactions을 사용하려면 DefaultKafkaProducerFactory의 setTransactionIdPrefix 메소드를 통해서 transactionIdPrefix를 설정하면 된다. KafkaTemplate, KafkaTransactionManager는 Producer 생성을 DefaultKafkaProducerFactory에 위임한다. DefaultKafkaProducerFactory는...


  • Kafka Transaction

    Kafka Transaction Kafka Client 0.11에 추가된 Kafka Transaction에 대해 학습한 내용을 정리한 글이다 Overview of delivery semantics At least once semantics At least once는 말 그대로 메시지를 적어도 한 번 전달한다는 의미이다. 이 때 발생할 수 있는 문제점은 메시지가 중복해서 전달될 수 있다는 것이다. Messages are never lost but may...