From f7570978d0b976782fdc224fc3805a28a253d736 Mon Sep 17 00:00:00 2001
From: Kezhu Wang <kezhuw@gmail.com>
Date: Wed, 11 Dec 2024 10:45:56 +0800
Subject: [PATCH] Fix default kafka retention.bytes config

---
 src/log/kafka.rs | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/log/kafka.rs b/src/log/kafka.rs
index e0fef3d..be63c47 100644
--- a/src/log/kafka.rs
+++ b/src/log/kafka.rs
@@ -265,7 +265,8 @@ impl LogClient for KafkaLogClient {
     }
 
     async fn create_log(&self, name: &str, retention: ByteSize) -> Result<()> {
-        let retention_bytes = retention.0.to_compact_string();
+        let retention_bytes =
+            if retention == ByteSize::default() { "-1".to_compact_string() } else { retention.0.to_compact_string() };
         let topics = [new_topic_config(name, self.replication, &retention_bytes)];
         let mut results = self.client.create_topics(&topics, &AdminOptions::default()).await?;
         let topic_result = results.pop().ok_or_else(|| anyhow!("no topic results in topic creation"))?;