Merge pull request #12434 from qzhuyan/fix/william/kafka-dont-stacktrace-when-no-partiion-count

kafka-bridge: dont stacktrace when no partition count
2024-02-01 15:09:45 +01:00 · 2024-02-01 15:09:45 +01:00 · 80ff1b1657
parent 3e518c1876 16444b7da9
commit 80ff1b1657
1 changed files with 2 additions and 0 deletions
--- a/apps/emqx_bridge_kafka/src/emqx_bridge_kafka_impl_producer.erl
+++ b/apps/emqx_bridge_kafka/src/emqx_bridge_kafka_impl_producer.erl
@ -378,6 +378,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,