From ffa4c4a31738e102b3ed9b6fe03dafe43534a516 Mon Sep 17 00:00:00 2001 From: niebayes Date: Fri, 22 Dec 2023 17:27:39 +0800 Subject: [PATCH] fix: style --- config/datanode.example.toml | 4 ++-- src/common/config/src/wal/kafka.rs | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/config/datanode.example.toml b/config/datanode.example.toml index bab945190b2c..261ec25158fc 100644 --- a/config/datanode.example.toml +++ b/config/datanode.example.toml @@ -58,9 +58,9 @@ sync_write = false # topic_name_prefix = "greptimedb_wal_kafka_topic" # Number of partitions per topic. # num_partitions = 1 -# The maximum log size an rskafka batch producer could buffer. +# The maximum log size a kafka batch producer could buffer. # max_batch_size = "4MB" -# The linger duration of an rskafka batch producer. +# The linger duration of a kafka batch producer. # linger = "200ms" # The maximum amount of time (in milliseconds) to wait for Kafka records to be returned. # max_wait_time = "100ms" diff --git a/src/common/config/src/wal/kafka.rs b/src/common/config/src/wal/kafka.rs index 02227a9540e6..bd7574c1613a 100644 --- a/src/common/config/src/wal/kafka.rs +++ b/src/common/config/src/wal/kafka.rs @@ -39,9 +39,9 @@ pub struct KafkaConfig { #[serde(skip)] #[serde(default)] pub compression: RsKafkaCompression, - /// The maximum log size an rskakfa batch producer could buffer. + /// The maximum log size a kakfa batch producer could buffer. pub max_batch_size: ReadableSize, - /// The linger duration of a rskafka batch producer. + /// The linger duration of a kafka batch producer. #[serde(with = "humantime_serde")] pub linger: Duration, /// The maximum amount of time (in milliseconds) to wait for Kafka records to be returned.