From 720a84d48bfb13862650dbb05c955c9fe1c7b301 Mon Sep 17 00:00:00 2001 From: Paulo Zulato Date: Fri, 9 Jun 2023 11:22:23 -0300 Subject: [PATCH] fix(kafka): fix timeout field for some kafka fields Change type of fields 'Partition Count Refresh Interval' and 'Offset Commit Interval' to avoid accepting values larger than allowed. Fixes https://emqx.atlassian.net/browse/EMQX-10196 Fixes https://emqx.atlassian.net/browse/EMQX-10199 --- apps/emqx_bridge_kafka/src/emqx_bridge_kafka.erl | 6 +++--- changes/ee/fix-10999.en.md | 1 + 2 files changed, 4 insertions(+), 3 deletions(-) create mode 100644 changes/ee/fix-10999.en.md diff --git a/apps/emqx_bridge_kafka/src/emqx_bridge_kafka.erl b/apps/emqx_bridge_kafka/src/emqx_bridge_kafka.erl index 64f2394c4..149346e4a 100644 --- a/apps/emqx_bridge_kafka/src/emqx_bridge_kafka.erl +++ b/apps/emqx_bridge_kafka/src/emqx_bridge_kafka.erl @@ -276,7 +276,7 @@ fields(producer_kafka_opts) -> )}, {partition_count_refresh_interval, mk( - emqx_schema:duration_s(), + emqx_schema:timeout_duration_s(), #{ default => <<"60s">>, desc => ?DESC(partition_count_refresh_interval) @@ -380,8 +380,8 @@ fields(consumer_kafka_opts) -> )}, {offset_commit_interval_seconds, mk( - pos_integer(), - #{default => 5, desc => ?DESC(consumer_offset_commit_interval_seconds)} + emqx_schema:timeout_duration_s(), + #{default => <<"5s">>, desc => ?DESC(consumer_offset_commit_interval_seconds)} )} ]. diff --git a/changes/ee/fix-10999.en.md b/changes/ee/fix-10999.en.md new file mode 100644 index 000000000..d9a38b326 --- /dev/null +++ b/changes/ee/fix-10999.en.md @@ -0,0 +1 @@ +Changed schema validation for Kafka fields 'Partition Count Refresh Interval' and 'Offset Commit Interval' to avoid accepting values larger then maximum allowed.