| 60 | } |
| 61 | |
| 62 | type OffsetCommitRequest struct { |
| 63 | ConsumerGroup string |
| 64 | ConsumerGroupGeneration int32 // v1 or later |
| 65 | ConsumerID string // v1 or later |
| 66 | GroupInstanceId *string // v7 or later |
| 67 | RetentionTime int64 // v2 or later |
| 68 | |
| 69 | // Version can be: |
| 70 | // - 0 (kafka 0.8.1 and later) |
| 71 | // - 1 (kafka 0.8.2 and later) |
| 72 | // - 2 (kafka 0.9.0 and later) |
| 73 | // - 3 (kafka 0.11.0 and later) |
| 74 | // - 4 (kafka 2.0.0 and later) |
| 75 | // - 5&6 (kafka 2.1.0 and later) |
| 76 | // - 7 (kafka 2.3.0 and later) |
| 77 | // - 8 (kafka 2.4.0 and later, first flexible version) |
| 78 | Version int16 |
| 79 | blocks map[string]map[int32]*offsetCommitRequestBlock |
| 80 | } |
| 81 | |
| 82 | func (r *OffsetCommitRequest) setVersion(v int16) { |
| 83 | r.Version = v |
nothing calls this directly
no outgoing calls
no test coverage detected