offset commit: use -1 for RetentionTimeMillis
This ensures that we do not expire the offset commit immediately.
I will shortly be converting all of this client to use kmsg.NewXyz
properly.
@@ -2031,6 +2031,7 @@ func (g *groupConsumer) commit(
Generation: g.generation,
MemberID: g.memberID,
InstanceID: g.cfg.instanceID,
+ RetentionTimeMillis: -1,
}
if ctx.Done() != nil {
