From 067beece758c3b3d0011a4c56578dc3689e54e28 Mon Sep 17 00:00:00 2001 From: Thales Macedo Garitezi Date: Fri, 28 Jun 2024 12:06:47 -0300 Subject: [PATCH] chore: add count to thrown error --- .../src/emqx_bridge_kafka_impl_producer.erl | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/apps/emqx_bridge_kafka/src/emqx_bridge_kafka_impl_producer.erl b/apps/emqx_bridge_kafka/src/emqx_bridge_kafka_impl_producer.erl index abdabef8c..b819925ac 100644 --- a/apps/emqx_bridge_kafka/src/emqx_bridge_kafka_impl_producer.erl +++ b/apps/emqx_bridge_kafka/src/emqx_bridge_kafka_impl_producer.erl @@ -324,12 +324,12 @@ on_query( }), do_send_msg(sync, KafkaMessage, Producers, SyncTimeout) catch - error:{invalid_partition_count, _Count, _Partitioner} -> + error:{invalid_partition_count, Count, _Partitioner} -> ?tp("kafka_producer_invalid_partition_count", #{ action_id => MessageTag, query_mode => sync }), - {error, {unrecoverable_error, invalid_partition_count}}; + {error, {unrecoverable_error, {invalid_partition_count, Count}}}; throw:{bad_kafka_header, _} = Error -> ?tp( emqx_bridge_kafka_impl_producer_sync_query_failed, @@ -390,12 +390,12 @@ on_query_async( }), do_send_msg(async, KafkaMessage, Producers, AsyncReplyFn) catch - error:{invalid_partition_count, _Count, _Partitioner} -> + error:{invalid_partition_count, Count, _Partitioner} -> ?tp("kafka_producer_invalid_partition_count", #{ action_id => MessageTag, query_mode => async }), - {error, {unrecoverable_error, invalid_partition_count}}; + {error, {unrecoverable_error, {invalid_partition_count, Count}}}; throw:{bad_kafka_header, _} = Error -> ?tp( emqx_bridge_kafka_impl_producer_async_query_failed,