1. ホームページ
  2. Apache Kafka Connector

  3. Apache Kafka Connector のトラブルシューティング

All Connectors

Apache Kafka Connector 4.9 のトラブルシューティング - Mule 4

Apache Kafka 用 Anypoint Connector (Apache Kafka Connector) をトラブルシューティングするには、スローされる一般的な例外メッセージの解釈について理解しておく必要があります。

SSL ログの有効化

SSL ログを有効化して、TLS 通信に関連する問題を調査します。

必要な詳細レベルに応じて SSL ログレベルを設定します。

  1. SSL ログの詳細のみを有効化します。

    javax.net.debug=ssl

  2. ハンドシェイクの詳細のみを有効化します。(ハンドシェイクプロトコルは、レコードプロトコル上で交換される一連のメッセージです。)

    javax.net.debug=ssl:handshake

  3. ハンドシェイクの詳細と SSL の詳細を同時に有効化します。

    javax.net.debug=ssl, handshake

  4. すべての詳細とトラフィックデータのダンプを有効化します。

    javax.net.debug=all

    このオプションは非常に冗長であり、通常の状況では不要です。
SSL ログは、HTTPS または他の TLS 接続のパフォーマンスに影響します。SSL ログは、特定の問題のトラブルシューティングを行うためにのみ有効化し、長期間有効にしないでください。SSL ログでは大量のログメッセージが生成されるため、有効にしたまま放置しておくと、ログファイルが溢れる可能性があります。

SSL ログを有効化する手順は、次のとおりです。

アプリケーションのランタイム設定でデバッグパラメーターを引数として設定します。

  1. Studio で、プロジェクトを右クリックし、​[Run (実行)] > [Run Configurations (実行設定)]​ を選択します。

  2. [Arguments (引数)]​ タブに移動して、​[VM arguments (VM 引数)]​ セクションで ​-M-Djavax.net.debug=ssl​ を追加します。

冗長例外ログの有効化

冗長例外ログを有効化して、デフォルトの切り捨てられた出力ではなくエラーの完全なスタック追跡を表示します。

  1. Studio で、プロジェクトを右クリックし、​[Run (実行)] > [Run Configurations (実行設定)]​ を選択します。

  2. [Arguments (引数)]​ タブに移動して、​[VM arguments (VM 引数)]​ セクションで引数を付加して ​mule.verbose.exceptions​ プロパティを追加します。次に例を示します。

    -XX:PermSize=128M -XX:MaxPermSize=256M -Dmule.verbose.exceptions=true

冗長ログの有効化

アプリケーションと Kafka Connector のやりとりが失敗する理由の理解を深めるには、コネクタの冗長ログを一時的に有効にします。

Mule アプリケーションのパフォーマンスに影響する可能性があるため、トラブルシューティングが完了したら、必ず拡張された冗長性を無効にしてください。

設定ファイルで冗長ログを有効にする手順は、次のとおりです。

  1. Anypoint Studio にアクセスし、​[Package Explorer]​ ビューに移動します。

  2. アプリケーションのプロジェクト名を開きます。

  3. src/main/resources​ フォルダーを開きます。

  4. フォルダー内の ​log4j2.xml​ ファイルを開きます。

  5. <Loggers>​ タグ内に ​<AsyncLogger>​ タグを追加します。

    			<Loggers>
				...
				<AsyncLogger name="com.mulesoft.connectors.kafka" level="DEBUG"/>
				...
			</Loggers>
    xml

  6. アプリケーションの変更を保存します。

  7. Package Explorer​ でプロジェクト名をクリックし、​[Run (実行)]​ > ​[Run As (別のユーザーとして実行)]​ > ​[Mule Application (Mule アプリケーション)]​ をクリックします。

一般的なエラーのトラブルシューティング

Apache Kafka Connector の一般的なエラーとその解決方法のリストを次に示します。

SSL キーストアを読み込めなかった

Kafka Connector 設定でクラスパスから必要なトラストストアファイルを読み込めない場合、次のエラーが表示されます。

org.mule.runtime.api.connection.ConnectionException: Failed to load SSL keystore
text

連動関係がバンドルされた Kafka Connector 設定では、必要なトラストストアファイルがクラスパスで使用できても接続を確立できません。

このエラーを解決する手順は、次のとおりです。

Kafka Connector 設定を使用して、必要なトラストストアファイルをメインアプリケーションを追加します。

clientDNSLookUp プロパティのトラブルシューティング

Kafka Connector バージョン 3.0.0 以降、コネクタの下位互換性を確保するために ​[DNS Lookup (DNS ルックアップ)]​ 項目のデフォルト値が削除されました。Kafka Connector では、以前のバージョンと同じ値が保持されますが、各値が次のプロパティに対応するようになりました。

Value (値) プロパティ

DEFAULT

use_all_dns_ips

USE_ALL_DNS_IPS

use_all_dns_ips

RESOLVE_CANONICAL_BOOTSTRAP_SERVERS_ONLY

resolve_canonical_bootstrap_servers_only

Null 値のパブリッシュのトラブルシューティング

Publish​ 操作では、入力として null を受け取ると、空のバイト配列をパブリッシュします。

この問題を回避するために、コネクタでは ​mule.kafka.publish.useNull​ ブール値システムプロパティを設定できます。

  • true​ に設定すると、コネクタは値として null を使用してメッセージをパブリッシュします。

  • false​ に設定するか、まったく設定しない場合、コネクタは空のバイト配列値を使用してメッセージをパブリッシュします。

システムプロパティの設定方法についての詳細は、​「システムプロパティの使用」​を参照してください。

スローされる一般的な例外メッセージの理解

スローされる一般的な例外メッセージとその解釈方法のリストを次に示します。

  • KAFKA:ALREADY_COMMITTED

    A commit fails because the commit is already performed. (コミットがすでに実行されているため、コミットが失敗しました。)

  • KAFKA:AUTHENTICATION_ERROR​(SECURITY)

    An authentication error is thrown. (認証エラーがスローされました。)

  • KAFKA:AUTHORIZATION_ERROR​(​CLIENT_SECURITY​)

    An authorization error occurred due to the client configuration or permissions. (クライアントの設定または権限が原因で認証エラーが発生しました。)

  • KAFKA:COMMIT_FAILED

    A commit fails with an unrecoverable error. (回復不能なエラーでコミットが失敗しました。)

  • KAFKA:CONNECTIVITY

    Either a connection could not be established or there is a connectivity error. (接続を確立できなかったか、接続エラーがあります。)

  • KAFKA:ILLEGAL_STATE

    The consumer is not subscribed to any topics, and no manually assigned partitions are set to consume from. (コンシューマーがトピックにサブスクライブされておらず、手動で割り当てられたパーティションがコンシューム元として設定されていません。)

  • KAFKA:INPUT_TOO_LARGE

    The input is too large for the broker. (ブローカーの入力が長すぎます。)

  • KAFKA:INVALID_ACK_MODE

    An acknowledgement (ACK) or negative acknowledgement (NACK) operation is run over a consumer that is not in ​`MANUAL`​ mode. (MANUAL モードでないコンシューマーで肯定応答 (ACK) または否定応答 (NACK) 操作が実行されています。)

  • KAFKA:INVALID_CONFIGURATION

    An invalid configuration value is set for the consumer or the producer. (コンシューマーまたはプロデューサーに無効な設定値が定義されています。)

  • KAFKA:INVALID_CONNECTION

    The referenced connection is invalid. (参照されている接続が無効です。)

  • KAFKA:INVALID_INPUT

    The parameters set for the operation are incorrect. (操作に設定されているパラメーターが正しくありません。)

  • KAFKA:INVALID_OFFSET

    The partition number set for the operation is less than ​`0`, is above the number of partitions, or is an invalid value. (操作に設定されているパーティション番号が 0 より小さいか、パーティション数を上回っているか、無効な値です。)

  • KAFKA:INVALID_TOPIC

    The topic selected for the operation is invalid, and there is no automatic generation of said topic. (操作に選択されたトピックが無効で、トピックの自動生成がありません。)This might also imply an invalid character in the topic name. (トピック名に無効な文字が含まれている可能性もあります。)

  • KAFKA:INVALID_TOPIC_PARTITION

    The topic partition combination selected for the operation is invalid, and there is no automatic generation of topics. (操作に選択されたトピックパーティションの組み合わせが無効で、トピックの自動生成がありません。)This might also imply an invalid character in the topic name, or a non-existing partition. (トピック名に無効な文字が含まれているか、パーティションが存在しない可能性もあります。)

  • KAFKA:NO_POLL_MADE

    No poll was made. (ポーリングが行われませんでした。)

  • KAFKA:NOT_FOUND

    For consume operations, the poll does not bring any records for the configured timeouts. (Consume 操作のポーリングで、設定されたタイムアウト中にレコードが取得されませんでした。)

  • KAFKA:OUT_OF_RANGE

    There is no reset policy defined, and the offsets for these partitions are either larger or smaller than the range of offsets the server has for the given partition. (リセットポリシーが定義されておらず、これらのパーティションのオフセットが、サーバーの特定のパーティションのオフセットの範囲よりも大きくなっているか、小さくなっています。)

  • KAFKA:PREVIOUS_ASSIGNATION

    subscribe() is called previously with topics or pattern without a subsequent call to unsubscribe(). (トピックまたはパターンがあり、unsubscribe() への後続のコールがない subscribe() が以前にコールされています。)

  • KAFKA:PRODUCER_FENCED

    Another producer with the same ​`transactional.id`​ is active. (同じ transactional.id を持つ別のプロデューサーがアクティブになっています。)

  • KAFKA:RETRY_EXHAUSTED

    The maximum number of retries for the operation is reached. (操作の最大再試行回数に達しました。)

  • KAFKA:SESSION_NOT_FOUND

    No associated session is found when executing an operation. (関連付けられたセッションが操作の実行時に見つかりませんでした。)

  • KAFKA:TIMEOUT

    A specific request takes longer than the configuration timeout values. (特定の要求に設定タイムアウト値よりも長い時間がかかっています。)

関連情報