Versions Compared

Old Version 34

changes.mady.by.user PSMON

Saved on

compared with

New Version Current

changes.mady.by.user PSMON

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

여기서 지정한 이름은 Kafka의 Brokers에 해당하는 제잎 앞단의 서브도메인이 해당하는 서브도메인이 됩니다.

Port는 9093으로 SSL만 지원합니다. ( KAFKA기준 정확한 보안 프로토콜명은 : SaslSsl , Kafka의 기능을 사용하여 핸드쉐이크가 이루어짐)

...

Warning

생성후 KAFKASUFACE가 활성화되는지 체크합니다.

( 저의경우 기본플랜으로 선택하였다가 리전변경및 여러번 실패후, 상위 플랜으로 재생성하여 활성화가 되었습니다.  -모든 리전지원합니다.   )


모든리전 지원하며, 기본플랜이아닌 표준플랜이상 KAFKA 인터페이스가 지원합니다.

양끝단을 Kafka 인터페이스로 맞추고, 클라우드로 관리되는 큐로 보여집니다.


Kafka의 Suface를 지원함으로, Kafka와 동일한 수준에서 다양한 클라이언트 연동이 가능합니다.

...

https://www.nuget.org/packages/AkkaDotModule.Webnori/  -작성기준 1.0.9

Nuget을 통해 위 모듈을 받으면 여기 실슬에 해당하는 샘플코드의 작동이 이용하면, 여기 설명하는 베이스로  작동 가능합니다.


SAS 정책추가

Code Block
themeEmacs
            var producerAkkaOption = new ProducerAkkaOption()
            {
                BootstrapServers = "webnori-kafka.servicebus.windows.net:9093",
                ProducerName = "webnori-kafka",
                SecuritOption = new KafkaSecurityOption()
                {
                    SecurityProtocol = SecurityProtocol.SaslSsl,
                    SaslMechanism = SaslMechanism.Plain,
                    SaslUsername = "$ConnectionString",
                    SaslPassword = "Endpoint=sb://webnori-kafka.servicebus.windows.net/;SharedAccessKeyName=kafka-client;SharedAccessKey=PfL0qRUm50AXZHRXLiVfnatIRI3OqAh+dT6Owsqrd2M=",
                    SslCaLocation = "./cacert.pem"
                }
            };

...

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


Kafka를 액터에 연결한 목적

...

Image Added

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


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

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

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

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

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

참고링크

...