From 4c2ae1725f1a49e58e0d84e0a62da68daa8fabc1 Mon Sep 17 00:00:00 2001
From: Nikita <nekitss2217@gmail.com>
Date: Mon, 20 May 2024 03:05:02 +0300
Subject: [PATCH] renamed env name for ends_at_latest_offsets

---
 src/main.rs | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

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)