yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(bridge-kafka): no stacktrace when fetch topic partition count fail

This commit is contained in:
William Yang 2024-01-31 14:24:54 +01:00
parent 42a4bc3382
commit 16444b7da9
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/emqx_bridge_kafka/src/emqx_bridge_kafka_impl_producer.erl
View File

@ -376,6 +376,8 @@ on_query_async(
), ),
do_send_msg(async, KafkaMessage, Producers, AsyncReplyFn) do_send_msg(async, KafkaMessage, Producers, AsyncReplyFn)
catch catch
error:{invalid_partition_count, _Count, _Partitioner} ->
{error, invalid_partition_count};
throw:{bad_kafka_header, _} = Error -> throw:{bad_kafka_header, _} = Error ->
?tp( ?tp(
emqx_bridge_kafka_impl_producer_async_query_failed, emqx_bridge_kafka_impl_producer_async_query_failed,