Page History

...

EventHub(Kafka)에 생산및 소비처리가 가능합니다.

Kafka를 액터에 연결한 목적

Image RemovedImage Added

참고 : http://eyeahs.github.io/blog/2017/01/24/a-journey-into-reactive-streams/

KafkaClient를 액터화하면서, Akka의 Stream기에 연결될수 있으며 Akka의 스트림은 흐름속도제어를 포함하여 스트림에 필요한 다양한 기능을 제공합니다.

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

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

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

입력장치의 밸브를 압력이 생긴만큼 밸브를 동적으로 잠그는 장치를 이야기합니다.

...