Consumer autocommit_stream does not seem to work

First the behavior - the app starts and processes all the messages, which by definition should mark those messages as consumed. stop the app and start it again, but the same messages are processed again, which is not one would expect. Now the setup - - consumer.into_autocommit_stream(...) needs 5 parameters - 1. coordinator_conn: follow the example in https://github.com/CallistoLabsNYC/samsa/blob/main/tests/offset.rs, where brokers use the same bootstrap_addrs as consumer, correlation_id = 1 and client_id are the same as for consumer, which are arbitrary. 2. group_id: arbitrary 3. generation_id: 1 4. member_id: arbitrary 5. retention_time_ms: 100000 Q: are there any issues with the setup?