refactor: update BaseOffset in cluster metadata serialization

codecrafters-io · Oct 4, 2024 · 87dd6c2 · 87dd6c2
1 parent dc05e88
commit 87dd6c2
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/protocol/serializer/cluster_metadata_binspec.go b/protocol/serializer/cluster_metadata_binspec.go
@@ -74,7 +74,7 @@ func writeClusterMetadataBinSpec(path string, directoryUUID string, logger *logg
 	}
 
 	recordBatch1 := kafkaapi.RecordBatch{
-		BaseOffset:           1,
+		BaseOffset:           0,
 		PartitionLeaderEpoch: 1,
 		Attributes:           0,
 		LastOffsetDelta:      0, // len(records) - 1
@@ -95,7 +95,7 @@ func writeClusterMetadataBinSpec(path string, directoryUUID string, logger *logg
 	}
 
 	recordBatch4 := kafkaapi.RecordBatch{
-		BaseOffset:           int64(0 + 0),
+		BaseOffset:           1,
 		PartitionLeaderEpoch: 1,
 		Attributes:           0,
 		LastOffsetDelta:      2, // len(records) - 1