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.