diff --git a/lib-ee/emqx_ee_bridge/i18n/emqx_ee_bridge_kafka.conf b/lib-ee/emqx_ee_bridge/i18n/emqx_ee_bridge_kafka.conf
index 6b770a752..6d2ca46ab 100644
--- a/lib-ee/emqx_ee_bridge/i18n/emqx_ee_bridge_kafka.conf
+++ b/lib-ee/emqx_ee_bridge/i18n/emqx_ee_bridge_kafka.conf
@@ -481,13 +481,13 @@ emqx_ee_bridge_kafka {
}
label {
en: "Kafka Consumer"
- zh: "Kafka Consumer"
+ zh: "Kafka 消费者"
}
}
consumer_opts {
desc {
- en: "Local MQTT data sink and Kafka bridge configs."
- zh: "本地MQTT数据汇和Kafka桥配置。"
+ en: "Local MQTT publish and Kafka consumer configs."
+ zh: "本地 MQTT 转发 和 Kafka 消费者配置。"
}
label {
en: "MQTT to Kafka"
@@ -501,23 +501,23 @@ emqx_ee_bridge_kafka {
}
label {
en: "Kafka Consumer"
- zh: "卡夫卡消费者"
+ zh: "Kafka 消费者"
}
}
consumer_mqtt_opts {
desc {
- en: "MQTT data sink."
- zh: "MQTT数据汇。"
+ en: "Local MQTT message publish."
+ zh: "本地 MQTT 消息转发。"
}
label {
- en: "MQTT data sink."
- zh: "MQTT数据汇。"
+ en: "MQTT publish"
+ zh: "MQTT 转发"
}
}
consumer_mqtt_topic {
desc {
en: "Local topic to which consumed Kafka messages should be published to."
- zh: "消耗的Kafka消息应该被发布到的本地主题。"
+ zh: "设置 Kafka 消息向哪个本地 MQTT 主题转发消息。"
}
label {
en: "MQTT Topic"
@@ -527,48 +527,44 @@ emqx_ee_bridge_kafka {
consumer_mqtt_qos {
desc {
en: "MQTT QoS used to publish messages consumed from Kafka."
- zh: "MQTT QoS用于发布从Kafka消耗的消息。"
+ zh: "转发 MQTT 消息时使用的 QoS。"
}
label {
- en: "MQTT Topic QoS"
- zh: "MQTT 主题服务质量"
+ en: "QoS"
+ zh: "QoS"
}
}
consumer_mqtt_payload {
desc {
en: "The payload of the MQTT message to be published.\n"
- "full_message
will encode all data available as a JSON object,"
+ "full_message
will encode available Kafka message attributes as a JSON object, including Key, Value, Timestamp and Headers"
"message_value
will directly use the Kafka message value as the "
"MQTT message payload."
zh: "要发布的MQTT消息的有效载荷。"
- "full_message
将把所有可用数据编码为JSON对象,"
- "message_value
将直接使用Kafka消息值作为MQTT消息的有效载荷。"
+ "full_message
将把所有可用数据编码为JSON对象,包括 Key,Value,Timestamp 和 Headers。"
+ "message_value
将直接使用 Kafka 消息值作为MQTT消息的 Payload。"
}
label {
en: "MQTT Payload"
- zh: "MQTT有效载荷"
+ zh: "MQTT Payload"
}
}
consumer_kafka_topic {
desc {
en: "Kafka topic to consume from."
- zh: "从Kafka主题消费。"
+ zh: "指定从哪个 Kafka 主题消费消息。"
}
label {
en: "Kafka topic"
- zh: "卡夫卡主题 "
+ zh: "Kafka 主题 "
}
}
consumer_max_batch_bytes {
desc {
en: "Maximum bytes to fetch in a batch of messages."
- "NOTE: this value might be expanded to retry when "
- "it is not enough to fetch even a single message, "
- "then slowly shrink back to the given value."
+ "Please note that if the configured value is smaller than the message size in Kafka, it may negatively impact the fetch performance."
zh: "在一批消息中要取的最大字节数。"
- "注意:这个值可能会被扩大,"
- "当它甚至不足以取到一条消息时,就会重试,"
- "然后慢慢缩回到给定的值。"
+ "如果该配置小于 Kafka 中消息到大小,则可能会影响消费性能。"
}
label {
en: "Max Bytes"
@@ -594,13 +590,13 @@ emqx_ee_bridge_kafka {
}
label {
en: "Offset Reset Policy"
- zh: "偏移重置政策"
+ zh: "偏移重置策略"
}
}
consumer_offset_commit_interval_seconds {
desc {
- en: "Defines the time interval between two OffsetCommitRequest
messages."
- zh: "定义了两个OffsetCommitRequest
消息之间的时间间隔。"
+ en: "Defines the time interval between two offset commit requests sent for each consumer group."
+ zh: "指定 Kafka 消费组偏移量提交的时间间隔。"
}
label {
en: "Offset Commit Interval"