test(optin): delete init log

taosdata · Dec 27, 2024 · b7cbac9 · b7cbac9
1 parent e79a82f
commit b7cbac9
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/taos-optin/src/tmq/mod.rs b/taos-optin/src/tmq/mod.rs
@@ -2749,8 +2749,6 @@ mod async_tests {
 
     #[tokio::test]
     async fn test_tmq_poll() -> anyhow::Result<()> {
-        pretty_env_logger::env_logger::init();
-
         use taos_query::prelude::{AsAsyncConsumer, AsyncQueryable, AsyncTBuilder, TryStreamExt};
         use taos_query::tmq::Timeout;
 
@@ -2772,7 +2770,7 @@ mod async_tests {
             .duration_since(std::time::UNIX_EPOCH)?
             .as_millis();
         let tmq = TmqBuilder::from_dsn(format!(
-            "taos:///tmq_poll_db?group.id={ms}&timeout=10s&enable.auto.commit=false"
+            "taos:///tmq_poll_db?group.id={ms}&timeout=10s&auto.offset.reset=earliest"
         ))?;
 
         let mut consumer = tmq.build().await?;