diff --git a/tests/test_metadata.rs b/tests/test_metadata.rs
index 3b2667a9c..e62bee556 100644
--- a/tests/test_metadata.rs
+++ b/tests/test_metadata.rs
@@ -22,6 +22,7 @@ fn create_consumer(group_id: &str) -> StreamConsumer {
         .set("session.timeout.ms", "6000")
         .set("api.version.request", "true")
         .set("debug", "all")
+        .set("auto.offset.reset", "earliest")
         .create()
         .expect("Failed to create StreamConsumer")
 }