chore: change default kafka port to 9092

config/datanode.example.toml

@@ -50,7 +50,7 @@ read_batch_size = 128
 sync_write = false
 
 # Kafka wal options, see `standalone.example.toml`.
-# broker_endpoints = ["127.0.0.1:9090"]
+# broker_endpoints = ["127.0.0.1:9092"]
 # max_batch_size = "4MB"
 # linger = "200ms"
 # produce_record_timeout = "100ms"

config/metasrv.example.toml

@@ -52,8 +52,8 @@ provider = "raft_engine"
 # There're none raft-engine wal config since meta srv only involves in remote wal currently.
 
 # Kafka wal config.
-# The broker endpoints of the Kafka cluster. ["127.0.0.1:9090"] by default.
-# broker_endpoints = ["127.0.0.1:9090"]
+# The broker endpoints of the Kafka cluster. ["127.0.0.1:9092"] by default.
+# broker_endpoints = ["127.0.0.1:9092"]
 # Number of topics to be created upon start.
 # num_topics = 64
 # Topic selector type.

config/standalone.example.toml

@@ -89,8 +89,8 @@ provider = "raft_engine"
 # There're none raft-engine wal config since meta srv only involves in remote wal currently.
 
 # Kafka wal options.
-# The broker endpoints of the Kafka cluster. ["127.0.0.1:9090"] by default.
-# broker_endpoints = ["127.0.0.1:9090"]
+# The broker endpoints of the Kafka cluster. ["127.0.0.1:9092"] by default.
+# broker_endpoints = ["127.0.0.1:9092"]
 
 # Number of topics to be created upon start.
 # num_topics = 64

src/common/config/src/wal.rs

@@ -90,7 +90,7 @@ mod tests {
     #[test]
     fn test_serde_kafka_config() {
         let toml_str = r#"
-            broker_endpoints = ["127.0.0.1:9090"]
+            broker_endpoints = ["127.0.0.1:9092"]
             max_batch_size = "4MB"
             linger = "200ms"
             produce_record_timeout = "100ms"
@@ -101,7 +101,7 @@ mod tests {
         "#;
         let decoded: KafkaConfig = toml::from_str(toml_str).unwrap();
         let expected = KafkaConfig {
-            broker_endpoints: vec!["127.0.0.1:9090".to_string()],
+            broker_endpoints: vec!["127.0.0.1:9092".to_string()],
             compression: RsKafkaCompression::default(),
             max_batch_size: ReadableSize::mb(4),
             linger: Duration::from_millis(200),

src/common/config/src/wal/kafka.rs

@@ -58,7 +58,7 @@ pub struct KafkaConfig {
 impl Default for KafkaConfig {
     fn default() -> Self {
         Self {
-            broker_endpoints: vec!["127.0.0.1:9090".to_string()],
+            broker_endpoints: vec!["127.0.0.1:9092".to_string()],
             compression: RsKafkaCompression::NoCompression,
             max_batch_size: ReadableSize::mb(4),
             linger: Duration::from_millis(200),

src/common/meta/src/wal.rs

@@ -75,7 +75,7 @@ mod tests {
         // Test serde raft-engine wal config with extra other wal config.
         let toml_str = r#"
             provider = "raft_engine"
-            broker_endpoints = ["127.0.0.1:9090"]
+            broker_endpoints = ["127.0.0.1:9092"]
             num_topics = 32
         "#;
         let wal_config: WalConfig = toml::from_str(toml_str).unwrap();
@@ -84,7 +84,7 @@ mod tests {
         // Test serde kafka wal config.
         let toml_str = r#"
             provider = "kafka"
-            broker_endpoints = ["127.0.0.1:9090"]
+            broker_endpoints = ["127.0.0.1:9092"]
             num_topics = 32
             selector_type = "round_robin"
             topic_name_prefix = "greptimedb_wal_topic"
@@ -98,7 +98,7 @@ mod tests {
         "#;
         let wal_config: WalConfig = toml::from_str(toml_str).unwrap();
         let expected_kafka_config = KafkaConfig {
-            broker_endpoints: vec!["127.0.0.1:9090".to_string()],
+            broker_endpoints: vec!["127.0.0.1:9092".to_string()],
             num_topics: 32,
             selector_type: TopicSelectorType::RoundRobin,
             topic_name_prefix: "greptimedb_wal_topic".to_string(),

src/common/meta/src/wal/kafka.rs

@@ -51,7 +51,7 @@ pub struct KafkaConfig {
 impl Default for KafkaConfig {
     fn default() -> Self {
         Self {
-            broker_endpoints: vec!["127.0.0.1:9090".to_string()],
+            broker_endpoints: vec!["127.0.0.1:9092".to_string()],
             num_topics: 64,
             selector_type: TopicSelectorType::RoundRobin,
             topic_name_prefix: "greptimedb_wal_topic".to_string(),