|
|
@@ -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,
|