「[[マイクロソフト系技術情報 Wiki>http://techinfoofmicrosofttech.osscons.jp/]]」は、「[[Open棟梁Project>https://github.com/OpenTouryoProject/]]」,「[[OSSコンソーシアム .NET開発基盤部会>https://www.osscons.jp/dotNetDevelopmentInfrastructure/]]」によって運営されています。

-戻る
--[[.NET開発]]
--[[Azure Event Hubsチュートリアル]]

* 目次 [#f057a5c0]
#contents

*概要 [#pb1fbfbf]
Confluent社製
-Apache Kafkaの最初の開発者によって設立されたConfluent社
-デジタルビジネスに不可欠なイベントストリーミングプラットフォームを提供

*詳細 [#i95d160f]
事前に、[[Kafkaエンドポイント付きのAzure Event Hubsを構築>Azure Event Hubsチュートリアル#f1eb5620]]しておく。

**インストール [#sa8c2bc4]
NuGetでインストールする。

**実装 [#kaa4196e]
以下、証明書の部分はコメントアウトした。~
(SslCaLocation で、cacert.pemを指定している)

***azure-event-hubs-for-kafka [#v5903ea2]
-プロデューサー~
https://github.com/Azure/azure-event-hubs-for-kafka/blob/master/quickstart/dotnet/EventHubsForKafkaSample/Worker.cs#L17
-コンシューマー~
https://github.com/Azure/azure-event-hubs-for-kafka/blob/master/quickstart/dotnet/EventHubsForKafkaSample/Worker.cs#L48

***より洗練された実装 [#d583af1b]
https://github.com/OpenTouryoProject/DataPipeline/tree/develop/Gateway/Kafka/Client/CS

-プロデューサー~
https://github.com/OpenTouryoProject/DataPipeline/tree/develop/Gateway/Kafka/Client/CS/Producer
-コンシューマー~
https://github.com/OpenTouryoProject/DataPipeline/tree/develop/Gateway/Kafka/Client/CS/Consumer

**認証 [#jd7de868]
-KafkaのSecurityProtocolで使用可能なもの。
-[[Azure Event HubsのKafkaエンドポイント>Azure Event Hubsチュートリアル#od841821]]の場合は、以下が使用可能。

***SAS [#nf2f30cd]
既定では[[SASトークン>Azure Event Hubsチュートリアル#y03d6018]]を使用する。

***OAuth [#x19dc323]
1.5からサポートがあるらしいが、サンプルが無い。

-Support for OAuthBearer SASL authentication mechanism~
· Issue #871 · confluentinc/confluent-kafka-dotnet · GitHub~
https://github.com/confluentinc/confluent-kafka-dotnet/issues/871

***証明書 [#le3a4e9d]
-インターフェイス上はSslCaLocationが存在。
-クライアント証明書は使用できなさそう。

**[[実際に送受信する>Azure Event Hubsチュートリアル#f1a3a29f]] [#j7001718]

*参考 [#z31a1dcb]
-Confluent | ネットワールド~
https://www.networld.co.jp/product/confluent/

-confluentinc/confluent-kafka-dotnet: Confluent's Apache Kafka .NET client~
https://github.com/confluentinc/confluent-kafka-dotnet

-Confluent Documentation
--Clients~
https://docs.confluent.io/ja-jp/home/clients/overview.html
---Kafka .NET クライアント~
https://docs.confluent.io/ja-jp/clients-confluent-kafka-dotnet/current/overview.html

----
Tags: [[:クラウド]], [[:Azure]], [[:.NET開発]], [[:.NET Core]], [[:.NET Standard]]

トップ   編集 差分 バックアップ 添付 複製 名前変更 リロード   新規 一覧 単語検索 最終更新   ヘルプ   最終更新のRSS