From 16444b7da9960fa99a8f324a7a16d6ca97b56e05 Mon Sep 17 00:00:00 2001 From: William Yang Date: Wed, 31 Jan 2024 14:24:54 +0100 Subject: [PATCH] fix(bridge-kafka): no stacktrace when fetch topic partition count fail --- apps/emqx_bridge_kafka/src/emqx_bridge_kafka_impl_producer.erl | 2 ++ 1 file changed, 2 insertions(+) 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 459e259d2..c253a42b6 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 @@ -376,6 +376,8 @@ on_query_async( ), do_send_msg(async, KafkaMessage, Producers, AsyncReplyFn) catch + error:{invalid_partition_count, _Count, _Partitioner} -> + {error, invalid_partition_count}; throw:{bad_kafka_header, _} = Error -> ?tp( emqx_bridge_kafka_impl_producer_async_query_failed,