Skip to content

Commit

Permalink
Consumer needs to read from earliest otherwise consumer will never re…
Browse files Browse the repository at this point in the history
…ad anything
  • Loading branch information
scanterog committed Nov 7, 2023
1 parent f3173d5 commit 6c8c5f0
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions tests/test_metadata.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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")
}
Expand Down

0 comments on commit 6c8c5f0

Please sign in to comment.