Page History

...

• 기본모드 : 기본적인 KafkaClient를 사용하면 생산과 소비기능만을 사용하게되며, 소비할시 별도의 로직처리를 하지 않는다고 하면 블락킹 모드로 작동될수 있습니다.
• 확장 : 생산과 소비의 입출력에 액터를 연결함으로 생산과 소비의 속도조절을 할수 있게되며, 작업자와 분리를 할수 있습니다.
• 배압장치(역압력을 통한 속도제어) : 출력버퍼가 비워지지않고 느리게 처리될시, 이를 동적으로 감지하고 소비를 적정으로 맞춰야 더 빠르고 안정적으로 처리된다는 이론이며
  이것은 실제 존재하는 장치에서 아이디어를 얻어왔으며, 리액티브스트림이 준수해야할 스펙중 하나입니다.

역압력조절기는 배압조절기는 실제 유체흐름을 안정적이고 빠르게 하기위해 실제 하기위해  존재하는장치이며

출력의 공간에 유체가 가득차게되면, 압력이 증가하고 출력의 흐름을 원활하게 하기위해

입력장치의 밸브를 압력이 생긴만큼 밸브를 동적으로 잠그는 출력의 압력을 감지하여, 입력부의 유량을 동적으로 안정적으로 조절하는 장치를 이야기합니다.

참고링크

• 이 아티컬의 샘플 소스 : https://github.com/psmon/AkkaDotModule/blob/master/AkkaDotBootApi/Test/TestAkka.cs
• AKKA.net Stream : https://getakka.net/articles/streams/buffersandworkingwithrate.html
• MS-원본문서 : https://docs.microsoft.com/ko-kr/azure/event-hubs/event-hubs-about
• Kafka-Security : https://springboot.cloud/31
• Alpakka.net(AkkaStream에 모든 메시지 시스템의 스트림을 연결하려는 프로젝트) : https://alpakka.getakka.net/documentation/index.html

...