Page History
...
여기서 지정한 이름은 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 | ||
|---|---|---|
| ||
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"
}
}; |
...