C＃コンフルエントAPIを使用したIBMメッセージハブの通信

Question

C＃Apache Kafka Confluent APIを使用してIBM Message Hubに接続するためのドキュメントを検索しようとしましたが、成功しませんでした。 githubの公式レポにはC＃のサンプルがありません。誰もがC＃を使用してibmメッセージハブと通信することができましたか？はいの場合、プロセスを共有できますか？

ありがとうございました。

更新： 私はIBM Message Hubとの通信に成功しました。

図書館：

1. librdkafka -... 0.11.0-RC2

2. 証明書から：https://curl.haxx.se/docs/caextract.html

3. Confluent.kafka.dll Confluent.Kafka 0.11.0-RC1

構成：

private static Dictionary<string, object> constructConfig(string brokerList, bool enableAutoCommit) => 
      new Dictionary<string, object> 
      { 
       { "group.id", "history" }, 
       { "enable.auto.commit", enableAutoCommit }, 
       { "auto.commit.interval.ms", 5000 }, 
       { "statistics.interval.ms", 60000 }, 
       { "bootstrap.servers", "ibmserver:port" }, 
       { "default.topic.config", new Dictionary<string, object>() 
        { 
         { "auto.offset.reset", "smallest" } 
        } 
       }, 
       {"ssl.ca.location",@"E:\cert\cacert.pem" },    
       {"api.version.request","true" }, 
       {"security.protocol","sasl_ssl" }, 
       {"sasl.mechanisms","PLAIN" }, 
       {"sasl.username","xxxx" }, 
       {"sasl.password","xxxxx" } 

      }; 

.NETバージョン：4.5.2

は、それが誰かのために時間を節約できます願っています。

多くの必要な情報を私に案内するEdoardo Comarに感謝します。

Answer 1

まだC＃サンプルを作成していません。

Confluent C＃Kafkaクライアントは、Cライブラリlibrdkafkaのラッパーで、バージョン0.9.5（この記事の執筆時点では最後のリリース）までは、認証に必要なSASL_SSLサポートを使用してWindows用に構築できませんでしたメッセージハブ

しかし、これは非常に最近のコミットのおかげで、librdkafka 0.11（このコメントを投稿しているので、リリース候補）に変更されました。

librdkafka 0.11（masterブランチ）がWindowsのメッセージハブで認証できることを確認しました。あなたはこれらの構成プロパティを設定する必要があります。

api.version.request=true 
security.protocol=sasl_ssl 
ssl.ca.location=<path to a valid cert.pem file> 
sasl.mechanisms=PLAIN 
sasl.username=<username from your Bluemix credentials> 
sasl.password=<password from your Bluemix credentials> 

で醸造のopensslを介してインストール（私はWindowsで有効なの.pem証明書ファイルを入手する方法を知りませんでしたので、私はMacOSのからのcert.pemファイルを上書きコピー/usr/local/etc/openssl）。 Ubuntuのcert.pem（/etc/opensslにあります）も同様に動作します。

幸運にも、あなたの進歩を最新のものにしてください。