Skip to content
This repository was archived by the owner on Jan 30, 2026. It is now read-only.

Commit 486aa41

Browse files
long
1 parent 80135c2 commit 486aa41

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

src/types.rs

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -136,7 +136,7 @@ pub struct StreamConfig {
136136
#[clap(flatten)]
137137
/// Timestamping configuration.
138138
pub timestamping: Option<TimestampingConfig>,
139-
#[arg(help("Example: 1d, 1w, 1y"))]
139+
#[arg(long, help("Example: 1d, 1w, 1y"))]
140140
/// Delete-on-empty configuration.
141141
pub delete_on_empty_min_age: Option<DeleteOnEmpty>,
142142
}
@@ -236,7 +236,9 @@ impl From<StreamConfig> for s2::types::StreamConfig {
236236

237237
let timestamping_config = config.timestamping.map(s2::types::TimestampingConfig::from);
238238

239-
let delete_on_empty = config.delete_on_empty_min_age.map(s2::types::DeleteOnEmpty::from);
239+
let delete_on_empty = config
240+
.delete_on_empty_min_age
241+
.map(s2::types::DeleteOnEmpty::from);
240242

241243
let mut stream_config = s2::types::StreamConfig::new();
242244
if let Some(storage_class) = storage_class {

0 commit comments

Comments
 (0)