CommitOffset return an Offset commit response or error
(request *OffsetCommitRequest)
| 608 | |
| 609 | // CommitOffset return an Offset commit response or error |
| 610 | func (b *Broker) CommitOffset(request *OffsetCommitRequest) (*OffsetCommitResponse, error) { |
| 611 | response := new(OffsetCommitResponse) |
| 612 | |
| 613 | err := b.sendAndReceive(request, response) |
| 614 | if err != nil { |
| 615 | return nil, err |
| 616 | } |
| 617 | |
| 618 | return response, nil |
| 619 | } |
| 620 | |
| 621 | // FetchOffset returns an offset fetch response or error |
| 622 | func (b *Broker) FetchOffset(request *OffsetFetchRequest) (*OffsetFetchResponse, error) { |
no test coverage detected