--- schema_version: "1" id: 32f0c8673e7a87f28732a9008bca8b7d32d4333274500017a1dc5a359530cfc0 title: Apache Kafka Connector 4.8 のトラブルシューティング collection: mulesoft version: current locale: ja-jp portal_url: https://docs.salesforce.com/mulesoft/current/ja-jp/kafka-connector/4.8/kafka-connector-troubleshooting.md canonical_url: https://docs.mulesoft.com/jp/kafka-connector/4.8/kafka-connector-troubleshooting source_site: docs.mulesoft.com content_type: documentation content_hash: ebaca54bb4ae7190339f870b32ab39d9bcf99a2be01a13b4c44f2aae83c6678f description: MuleSoft Documentation Site release: "4.8" latest: false --- # Apache Kafka Connector 4.8 のトラブルシューティング Apache Kafka 用 Anypoint Connector (Apache Kafka Connector) をトラブルシューティングするには、スローされる一般的な例外メッセージの解釈について理解しておく必要があります。 Unresolved include directive in modules/ROOT/pages/kafka-connector-troubleshooting.adoc - include::connectors::partial$ssl-logs.adoc\[\] Unresolved include directive in modules/ROOT/pages/kafka-connector-troubleshooting.adoc - include::connectors::partial$verbose-exception-logs.adoc\[\] Unresolved include directive in modules/ROOT/pages/kafka-connector-troubleshooting.adoc - include::connectors::partial$verbose-logs-com.adoc\[\] ## [](#一般的なエラーのトラブルシューティング)一般的なエラーのトラブルシューティング Apache Kafka Connector の一般的なエラーとその解決方法のリストを次に示します。 - [SSL キーストアを読み込めなかった](#failed-to-load-ssl-keystore) ### [](#failed-to-load-ssl-keystore)SSL キーストアを読み込めなかった Kafka Connector 設定でクラスパスから必要なトラストストアファイルを読み込めない場合、次のエラーが表示されます。 ```text org.mule.runtime.api.connection.ConnectionException: Failed to load SSL keystore ``` 連動関係がバンドルされた Kafka Connector 設定では、必要なトラストストアファイルがクラスパスで使用できても接続を確立できません。 このエラーを解決する手順は、次のとおりです。 Kafka Connector 設定を使用して、必要なトラストストアファイルをメインアプリケーションを追加します。 ## [](#clientdnslookup-プロパティのトラブルシューティング)clientDNSLookUp プロパティのトラブルシューティング Kafka Connector バージョン 3.0.0 以降、コネクタの下位互換性を確保するために ​**\[DNS Lookup (DNS ルックアップ)\]**​ 項目のデフォルト値が削除されました。Kafka Connector では、以前のバージョンと同じ値が保持されますが、各値が次のプロパティに対応するようになりました。
値 プロパティ

DEFAULT

use_all_dns_ips

USE_ALL_DNS_IPS

use_all_dns_ips

RESOLVE_CANONICAL_BOOTSTRAP_SERVERS_ONLY

resolve_canonical_bootstrap_servers_only
## [](#null-値のパブリッシュのトラブルシューティング)Null 値のパブリッシュのトラブルシューティング **Publish**​ 操作では、入力として null を受け取ると、空のバイト配列をパブリッシュします。 この問題を回避するために、コネクタでは ​`mule.kafka.publish.useNull`​ ブール値システムプロパティを設定できます。 - `true`​ に設定すると、コネクタは値として null を使用してメッセージをパブリッシュします。 - `false`​ に設定するか、まったく設定しない場合、コネクタは空のバイト配列値を使用してメッセージをパブリッシュします。 システムプロパティの設定方法についての詳細は、​[「システムプロパティの使用」](https://docs.mulesoft.com/mule-runtime/latest/mule-app-properties-system)​を参照してください。 ## [](#スローされる一般的な例外メッセージの理解)スローされる一般的な例外メッセージの理解 スローされる一般的な例外メッセージとその解釈方法のリストを次に示します。 - 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. (特定の要求に設定タイムアウト値よりも長い時間がかかっています。) ## [](#関連情報)関連情報 - [Anypoint Connector の概要](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors) - [Apache Kafka Connector リファレンス](https://docs.mulesoft.com/jp/kafka-connector/4.8/kafka-connector-reference) - [MuleSoft ヘルプセンター](https://help.mulesoft.com)