Connector Status Abnormal Alert
Connector Status Abnormal アラートは、EMQX Cloud のデプロイメント内の1つ以上のデータ統合コネクターが一定期間にわたり正常な状態を維持していないことを示します。
これは通常、EMQX Cloud と対象の外部システム間の接続が不安定または利用不可であることを意味します。その結果、メッセージが対象のサービスに配信されない可能性があります。
外部サービスへの到達不可またはネットワーク障害
症状
EMQX Cloud が対象の外部システムに対して安定した接続を確立または維持できません。
connection refused、timeout、unreachable、econnrefused といったエラーが Deployment Logs に表示され、コネクターの状態が Disconnected、Error、またはクラスター内のノード間で不整合となります。
主な原因
- 対象システムが利用不可または正常に稼働していない。
- ネットワークが途切れているか不安定である。
- 対象サービスのポートが閉じている。
- ネットワークポリシーにより EMQX Cloud と対象サービス間のアクセスが制限されている。
対処方法
- 対象システムが稼働中であり、リッスンポートが開いていることを確認してください。
- EMQX Cloud テクニカルサポートと連携し、
ping、telnet、curlなどのツールを使って EMQX Cloud から対象サービスへの接続性をテストしてください。 - VPC、許可リスト、ファイアウォール、セキュリティグループのルールが EMQX から対象サービスへのアクセスを許可しているか確認してください。
認証失敗または権限不足
症状
コネクターが一時的に接続した後すぐに切断されます。これはアカウント、認証情報、認証設定が無効であるか、アカウントに必要な権限がないためです。
authentication failed、unauthorized、permission denied といったエラーが Deployment Logs に表示されます。
主な原因
- ユーザー名、パスワード、APIキー、証明書が誤っている。
- 認証情報が期限切れまたは取り消されている。
- 対象システムがコネクターに必要なアクセス権や書き込み権限を付与していない。
対処方法
- コネクター設定のユーザー名、パスワード、APIキー、証明書を確認してください。
- 対象システムがアカウントに対して、データベースの書き込み権限、Kafkaのプロデューサー権限、クラウドのIAM権限など必要な権限を付与しているか確認してください。
対象システムの過負荷またはリソース不足
症状
過負荷またはリソース不足の対象システムが接続や書き込み要求にタイムリーに応答できず、コネクターの状態が不安定になります。
対象システムのログに timeout や server busy といったエラーが記録され、コネクターは Connected と Disconnected を繰り返すか、クラスター内で状態が不整合となります。
主な原因
- 対象システムの CPU、メモリ、接続容量が枯渇している。
- リクエストの同時実行数が対象システムの処理能力を超えている。
対処方法
- 対象システムの CPU、メモリ、接続使用状況を確認してください。
- EMQX で適切な接続プールサイズ、タイムアウト、バッファリング、リトライポリシーを設定してください。
- 必要なスループットをサポートできるように対象システムをスケールアウトしてください。
コネクター設定の誤り
症状
1つ以上のコネクター設定パラメーターが誤っているため、EMQX が対象リソースにアクセスできず、安定した接続が確立されません。
invalid config、unknown topic、table not found といったエラーが Deployment Logs に表示されます。
主な原因
- データベースのアドレス、ポート、インスタンス情報が誤っている。
- Kafka トピックが存在しない、または名前が誤っている。
- データベースのテーブルが存在しないか、スキーマが不適合である。
対処方法
- 対象のアドレス、ポート、トピック、テーブル名が対象環境と一致しているか確認してください。
- 設定を修正し、コネクターを再保存してください。
トラブルシューティング
EMQX Cloud コンソールにログインし、影響を受けているデプロイメントに入ります。
データ統合 -> コネクター に移動し、アラートが発生したコネクターの状態を確認します。

Deployment Logs を開き、Error Type を Data Integration に設定して関連するエラーを特定します。

ログの詳細から、原因がネットワーク障害、認証失敗、対象システムの過負荷、設定誤りのいずれかかを特定します。
コネクター設定を開き、編集 をクリックしてパラメーターや認証情報を修正します。
設定を保存し、コネクターを再起動して、状態が
Connectedに変わることを確認してください。