クラスターからのデータをアプリケーションで処理しようとすると、次のようなエラーメッセージが発生することがあります。作成するアクセス許可がアプリケーションに与えられていることを確認してください。アプリケーションを記述するときには、次のようにメソッド呼び出しを連結することがよくあります。スタックトレースはそれほど役に立たない可能性があります。エラーが発生したことは推測できても、行内での正確な場所をスタックトレースから特定することはできません。簡単な対応策として、メソッドチェーンを複数行に分割すると、スタックトレースによって返される行番号から実際のエラーの場所を特定しやすくなります。アクセスすることで視覚化できます。情報が含まれています(つまり、ランタイム情報ではありません)。この情報は、すべてのノード、(グローバル)ストア、そしてノードやストアが互いにどのように接続されているかを表します。各ノードについて、ノード名や入出力トピック(ソースおよびシンクの場合)などの詳細情報を取得できます。ノードはサブトポロジー(トピックのみを通じて接続されたノードのグループ)でグループ化されます。出力すると次のようになります。アプリケーションの内部トポロジーを視覚化できます。トポロジーの例を以下に示します。すべてのソース、シンク、それらを支えるトピック、およびすべての中間ノードとそのステートストアが収集され、出力されます。詳しい情報が返され、たとえば、実行中の各ストリームスレッドに現在割り当てられているタスクが含まれます。非推奨となっています。メソッドを呼び出すことができます。ストリームを取得すると、加えられた変更を調査できます。使用するとファイルに書き込むことができます。使用する例を以下に示します。.print(Printed.toSysOut());出力は結合後のレコードになります。いくつかのサンプルデータでの出力例は次のようになります。次のような例外が発生した場合は、複数の原因が考えられます。アプリケーションのタイムスタンプエクストラクターが、レコードから有効なタイムスタンプを抽出できなかったことを示します。これは通常、レコードの問題(レコードにタイムスタンプが含まれていないなど)を示唆していますが、アプリケーションで使用されているタイムスタンプエクストラクターの問題やバグを示している場合もあります。メッセージフォーマットに導入されました)。以前)またはサードパーティのプロデューサークライアントによって書き込まれたトピックを消費している場合に発生する可能性があります。アップグレードした後にも発生することがあります。メッセージのタイムスタンプが含まれません。ような代替のタイムスタンプエクストラクターを使用すると、負のタイムスタンプをより穏便に処理できます。項を参照してください。カスタムのタイムスタンプエクストラクターを使用している場合は、エクストラクターで無効な(負の)タイムスタンプが適切に処理されることを確認してください。定義はアプリケーションのセマンティクスによって異なります。レコードから有効なタイムスタンプを直接抽出できない場合は、デフォルトのタイムスタンプや推定のタイムスタンプを返すことができます。使用して、イベント時刻の処理から処理時刻のセマンティクスに切り替えることもできます。この状況に対してこのようなフォールバックが適切な対応かどうかは、ユースケースによって異なります。書き込まれた根本的な原因を特定して修正することが何よりもまず必要です。トピックに書き込むこともできます。タイムスタンプエクストラクターが問題を引き起こす場合¶この状況では、エラーのあるエクストラクターをデバッグして修正する必要があります。解決するまでの間、問題を修正するカスタムのタイムスタンプエクストラクターを作成し、当面はそのエクストラクターを使用するようにアプリケーションを構成できます。インスタンスを返す必要があります。なることがあります)。基づいてトリガーされるのではなく、純粋にデータドリブンになります(つまり、内部で追跡されるイベント時刻によって駆動されます)。よって抽出されたレコードのタイムスタンプから導かれます。関数をスケジュールしたとします。