diff --git a/src/main.rs b/src/main.rs
index 8a13864..56a2c50 100644
--- 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)