Page History
| Info |
|---|
Apache Kafka(아파치 카프카)는 LinkedIn에서 개발된 분산 메시징 시스템으로써 2011년에 오픈소스로 공개되었다. 대용량의 실시간 로그처리에 특화된 아키텍처 설계를 통하여 akka.net을 akka.net을 통해 kafka를 연동하여 몇가지 유용한 kafka의 전송기능을 조금더 풍부하게 개조해보겠습니다샘플을 작성해보겠습니다. src위치 : http://git.webnori.com/projects/AKKA/repos/akkastudy/browse/Solution/ServiceB/STUDY/KafkaTest.cs |
...
At-Least-Once Delivery 를 활용하여 Kafka에게 메시지를 꼭 실패에 대응하여
중복없이 한번만 전송하는 모듈을 작성해보겠습니다.
TestCase :
- Kafka에 메시지 20개를 보낸다.
- 테스트를 위해 짝수번째 메시지는, 중간에 드롭을 시킨다.
- 전송부쪽에서는, Kafka의 성공메시지를 못받았기때문에 홀수번째 메시지를 다시 보낸다.
- 결국 20개의 메시지가 모두 성공한다.
...