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

refactor: rename config parameter

This commit is contained in:
Kjell Winblad 2023-06-08 15:58:19 +02:00
parent 6f2271e9f0
commit d524f8c805
3 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -303,12 +303,12 @@ fields(producer_kafka_opts) ->
desc => ?DESC(query_mode) desc => ?DESC(query_mode)
} }
)}, )},
{query_mode_sync_timeout, {sync_query_timeout,
mk( mk(
emqx_schema:duration_ms(), emqx_schema:duration_ms(),
#{ #{
default => <<"5s">>, default => <<"5s">>,
desc => ?DESC(query_mode_sync_timeout) desc => ?DESC(sync_query_timeout)
} }
)} )}
]; ];

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

@ -50,7 +50,7 @@ on_start(InstId, Config) ->
kafka := KafkaConfig = #{ kafka := KafkaConfig = #{
message := MessageTemplate, message := MessageTemplate,
topic := KafkaTopic, topic := KafkaTopic,
query_mode_sync_timeout := QueryModeSyncTimeout sync_query_timeout := SyncQueryTimeout
}, },
metadata_request_timeout := MetaReqTimeout, metadata_request_timeout := MetaReqTimeout,
min_metadata_refresh_interval := MinMetaRefreshInterval, min_metadata_refresh_interval := MinMetaRefreshInterval,
@ -108,7 +108,7 @@ on_start(InstId, Config) ->
kafka_topic => KafkaTopic, kafka_topic => KafkaTopic,
producers => Producers, producers => Producers,
resource_id => ResourceId, resource_id => ResourceId,
query_mode_sync_timeout => QueryModeSyncTimeout sync_query_timeout => SyncQueryTimeout
}}; }};
{error, Reason2} -> {error, Reason2} ->
?SLOG(error, #{ ?SLOG(error, #{
@ -201,7 +201,7 @@ on_query(
#{ #{
message_template := Template, message_template := Template,
producers := Producers, producers := Producers,
query_mode_sync_timeout := SyncTimeout sync_query_timeout := SyncTimeout
} }
) -> ) ->
?tp(emqx_bridge_kafka_impl_producer_sync_query, #{}), ?tp(emqx_bridge_kafka_impl_producer_sync_query, #{}),

6
rel/i18n/emqx_bridge_kafka.hocon
View File

@ -166,7 +166,7 @@ consumer_offset_reset_policy.label:
partition_count_refresh_interval.desc: partition_count_refresh_interval.desc:
"""The time interval for Kafka producer to discover increased number of partitions. """The time interval for Kafka producer to discover increased number of partitions.
After the number of partitions is increased in Kafka, EMQX will start taking the After the number of partitions is increased in Kafka, EMQX will start taking the
discovered partitions into account when dispatching messages per <code>partition_strategy</code>.""" discovered partitions into account when dispatching messages per <code>partition_strategy</code>."""
partition_count_refresh_interval.label: partition_count_refresh_interval.label:
@ -364,10 +364,10 @@ query_mode.desc:
query_mode.label: query_mode.label:
"""Query mode""" """Query mode"""
query_mode_sync_timeout.desc: sync_query_timeout.desc:
"""This parameter defines the timeout limit for synchronous queries. It applies only when the bridge query mode is configured to 'sync'.""" """This parameter defines the timeout limit for synchronous queries. It applies only when the bridge query mode is configured to 'sync'."""
query_mode_sync_timeout.label: sync_query_timeout.label:
"""Synchronous Query Timeout""" """Synchronous Query Timeout"""
} }