diff --git a/offset_manager.go b/offset_manager.go index 572bbf1fb..53b9bf0eb 100644 --- a/offset_manager.go +++ b/offset_manager.go @@ -250,23 +250,19 @@ func (om *offsetManager) Commit() { } func (om *offsetManager) flushToBroker() { - var ( attempt int ) - for { req := om.constructRequest() if req == nil { return } - broker, err := om.coordinator() if err != nil { om.handleError(err) return } - resp, err := broker.CommitOffset(req) if err != nil { om.handleError(err) @@ -282,7 +278,6 @@ func (om *offsetManager) flushToBroker() { om.handleResponse(broker, req, resp) return } - } func (om *offsetManager) shouldRetry(resp *OffsetCommitResponse, attempt int) bool {