問題タブ [apache-pulsar]

Run Pulsar local から Ubuntu 18.04.2 LTS に apache pulsar スタンドアロン v2.3 をセットアップしました。認証なしで正常に動作します。security-tls-transportとsecurity-tls-authenticationを使用して TLS 証明書を構成しようとしました。リンクに記載されているように、次broker.confの構成を変更しました。コマンドを使用して pulsar を実行し、以下のコマンドを使用してメッセージを送信します。client.confstandalone.confbin/pulsar standalone

bin/pulsar-client produce my-topic --messages "hello-pulsar"

しかし、それは次のエラーをスローします

誰でもこれを解決するのを手伝ってもらえますか?

Kafka からのデータを消費するために、完全に分離されたトピックで複数のコンシューマーを持つことができます。では、 kafka と pulsar の違いを共有no shared consumptionするページ ( https://streaml.io/blog/pulsar-streaming-queuing ) の意味は何ですか?

本番環境に対応した低遅延の分散ログ用の既存のソフトウェアはありますか? アイデアは、サービス自体に送信される前に、入力メッセージをサービスに保存することです。サービスが起動すると、その状態の最新のスナップショットが取得され、入力メッセージが再生されます。サービスが確定的である場合、サービスの複数のインスタンスを一度に実行できます。これにより、高可用性とゼロ ダウンタイムの導入の両方が実現します。

利用可能なログは多数ありますが、遅延が大きいもの、分散/クラスタ化が十分でないもの、本番環境にまだ対応していないものがあります。

利用可能な分散ログ ソフトウェア

• カフカ

• NATS ストリーミング

• タンク

• 分散ログ

• パルサー

• ロケットMQ

• リフトブリッジ

• ジョッコ

• LogDevice

要件

• メッセージ/イベントの永続性 (メモリ内またはディスク上)

• トピック/パーティション内のメッセージの順序

• At-least-once-delivery: パブリッシャーとサーバー間 (パブリッシュ操作用) およびサブスクライバーとサーバー間 (メッセージ配信を確認するため) のメッセージ確認応答

• サブジェクトごとの履歴メッセージの再生: 新しいサブスクリプションは、サブスクライブしたサブジェクトのチャネル用に保存されたメッセージのストリーム内の開始位置を指定できます。

• 高可用性: 複数のクラスター化されたノードがあり、それらの間でレプリケーションが行われている必要があります

• 低遅延: 2 つのノードがメッセージを受信して​​から送信するまで待機する場合は、低遅延でなければなりません。理想的には数ミリ秒ですが、数十ミリ秒以上ではありません。これが、Kafka がこれに適していないと思われる主な理由です。

見逃したオプションはありますか？