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

Merge pull request #10999 from paulozulato/fix-kafka-time-field-too-large 

fix(kafka): fix timeout field for some kafka fields
This commit is contained in:
Paulo Zulato 2023-06-09 15:29:59 -03:00 committed by GitHub
parent fa140c1d68 720a84d48b
commit 7c63f20aa8
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
apps/emqx_bridge_kafka/src/emqx_bridge_kafka.erl
View File

@ -276,7 +276,7 @@ fields(producer_kafka_opts) ->
)}, )},
{partition_count_refresh_interval, {partition_count_refresh_interval,
mk( mk(
emqx_schema:duration_s(), emqx_schema:timeout_duration_s(),
#{ #{
default => <<"60s">>, default => <<"60s">>,
desc => ?DESC(partition_count_refresh_interval) desc => ?DESC(partition_count_refresh_interval)
@ -380,8 +380,8 @@ fields(consumer_kafka_opts) ->
)}, )},
{offset_commit_interval_seconds, {offset_commit_interval_seconds,
mk( mk(
pos_integer(), emqx_schema:timeout_duration_s(),
#{default => 5, desc => ?DESC(consumer_offset_commit_interval_seconds)} #{default => <<"5s">>, desc => ?DESC(consumer_offset_commit_interval_seconds)}
)} )}
]. ].

1
changes/ee/fix-10999.en.md Normal file
View File

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