style:fix style

IBM · Sep 22, 2021 · 2ccbe75 · 2ccbe75
1 parent 7f4d80a
commit 2ccbe75
Showing 1 changed file with 0 additions and 5 deletions.
diff --git 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 {