データ購読 Kafka版
ダウンロード
フォーカスモード
フォントサイズ
データを消費できないのはなぜですか。
ネットワークの問題を切り分けます。KafkaサーバーアドレスはTencent Cloudの内部ネットワークアドレスであり、Tencent Cloudのサブスクリプションインスタンスと同じ地域のVPC内でのみアクセスできます。
購読トピック、内部ネットワークアドレス、コンシューマグループ名、アカウント、パスワードなどが正しいかどうかを確認します。データ購読コンソールで購読名をクリックして、購読詳細ページと消費管理ページに移動して確認できます。
暗号化パラメータが正しいかどうかを確認し、Kafkaが使用する認証メカニズムを参照してください。
データ形式はどのようなものですか。
データ購読 Kafka版は Protobuf を使用してシリアル化します。Protobuf プロトコルファイルはこちらからダウンロードできます。Demo プロジェクトにもプロトコルファイルが含まれています。詳細は生産および消費ロジックの説明を参照してください。
Kafkaはどの認証メカニズムを使用しますか。
Kafkaはどの認証メカニズムを使用しますか。
以下に示します：
Kafka commitはいつ実行するのか
まず、Kafka の enable_auto_commit パラメータを false に設定して、自動 commit を無効にしてください。プロデューサーはメッセージシーケンス内の適切な位置に Checkpoint メッセージを挿入します。コンシューマーは Checkpoint メッセージを消費した後に commit を行います。これにより、メッセージの整合性を確保できます。
サーバー側メッセージの保持期間と消費オフセットの設定方法
サーバー側のメッセージは1日間保持されます。必要に応じて、Kafka の auto_offset_reset パラメータを earliest または latest に設定できます。特定の offset から消費を開始する必要がある場合は、Kafka Client が提供する seek 機能を利用して、消費 offset を再設定できます。
フィードバック