Page History
...
AkkaDotModule은 AKKA.net을 포함 KAFKA사용을 조금더 쉽게 한 사용하게끔 웹노리 주인장이 변종한 모듈이며
Akka.net의 기능과 파생된 녀석들이 방대하기때문에, 필요한만큼만 안정적인 버전으로 패키징한 모듈입니다.
https://www.nuget.org/packages/AkkaDotModule.Webnori/ -작성기준 1.0.9
Nuget을 통해 위 모듈을 받으면 여기 실슬에 해당하는 샘플코드의 작동이 가능합니다.
SAS 정책추가
Code Block | ||
---|---|---|
| ||
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" } }; |
...