renamed env name for ends_at_latest_offsets

delta-io · May 25, 2024 · 1d8bf0b · 1d8bf0b
1 parent ef4b050
commit 1d8bf0b
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/src/main.rs b/src/main.rs
@@ -321,8 +321,7 @@ fn build_app() -> Command {
                 .arg(Arg::new("table_location")
                     .env("TABLE_LOCATION")
                     .help("The Delta table location to write out")
-                    .required(true)
-                )
+                    .required(true))
                 .arg(Arg::new("kafka")
                     .short('k')
                     .long("kafka")
@@ -448,7 +447,7 @@ This can be used to provide TLS configuration as in:
                 .arg(Arg::new("end")
                     .short('e')
                     .long("ends_at_latest_offsets")
-                    .env("TURN_OFF_AT_KAFKA_TOPIC_END")
+                    .env("ENDS_AT_LATEST_OFFSETS")
                     .required(false)
                     .num_args(0)
                     .action(ArgAction::SetTrue)