Page History
...
EventHub(Kafka)에 생산및 소비처리가 가능합니다.
참고링크
...
Kafka를 액터에 연결한 목적
KafkaClient를 액터화하면서, Akka의 Stream기에 연결될수 있으며 Akka의 스트림은 흐름속도제어를 포함하여 스트림에 필요한 다양한 기능을 제공합니다.
- 기본모드 : 기본적인 KafkaClient를 사용하면 생산과 소비기능만을 사용하게되며, 소비할시 별도의 로직처리를 하지 않는다고 하면 블락킹 모드로 작동될수 있습니다.
- 확장 : 생산과 소비의 입출력에 액터를 넣음으로 생산과 소비의 속도조절을 할수 있게되며, 작업자와 분리를 할수 있습니다.
- 역압력 : 출력버퍼가 비워지지않고 느리게 처리될시, 소비를 늦춰야 더 빠르게 처리된다는 이론
역압력조절기는 실제 유체흐름을 안정적이고 빠르게 하기위해 실제 존재하는장치이며
출력의 공간에 유체가 가득차게되면, 압력이 증가하고 출력의 흐름을 원활하게 하기위해
입력장치의 밸브를 압력이 생긴만큼 밸브를 동적으로 잠그는 장치를 이야기합니다.
참고링크
- 이 아티컬의 샘플 소스 : https://github.com/psmon/AkkaDotModuleMS-원본문서 : https:/blob/docs.microsoft.com/ko-kr/azure/event-hubs/event-hubs-about
- 레거시 모듈로 사용하기 : https://docs.microsoft.com/ko-kr/azure/event-hubs/event-hubs-dotnet-standard-get-started-send-legacy
- Kafka-Docker-AkkaStream Mode : KAFKA 닷넷코어에서 쉽고강력하게 활용하기
- master/AkkaDotBootApi/Test/TestAkka.cs
- AKKA.net Stream : https://getakka.net/articles/streams/introductionbuffersandworkingwithrate.html
- KafkaMS-Security 원본문서 : https://springboot.cloud/31공유 Access 서명 : https://docs.microsoft.com/ko-kr/azure/event-hubs/authenticateevent-sharedhubs-access-signatureabout
- Kafka-Security : https://springboot.cloud/31