0518 improve kafka connection error logs #13070
Merged
+53
−25
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Fixes EMQX-12403
Release version: v/e5.7.1
Summary
Example log when Kafka's advertised listener is unreachable.
2024-05-18T19:13:48.412913+02:00 [warning] msg: add_channel_failed, id: <<"connector:kafka_producer:k1">>, reason: #{cause => "no_connected_partition_leader",kafka_topic => "test-topic-2",kafka_client => <<"connector:kafka_producer:k1">>,first_error => {1,{down,#{reason => unresolvable_hostname,host => <<"localhostx:9092">>}}},total_errors => 2}, channel_id: <<"action:kafka_producer:k1:connector:kafka_producer:k1">>
PR Checklist
Please convert it to a draft if any of the following conditions are not met. Reviewers may skip over until all the items are checked:
changes/(ce|ee)/(feat|perf|fix|breaking)-<PR-id>.en.md
filesChecklist for CI (.github/workflows) changes
changes/
dir for user-facing artifacts update