make fmt

balance_strategy_test.go

@@ -203,7 +203,7 @@ func Test_prepopulateCurrentAssignments(t *testing.T) {
 		wantErr                bool
 	}{
 		{
-			name:                   "Empty map",
+			name: "Empty map",
 			wantCurrentAssignments: map[string][]topicPartitionAssignment{},
 			wantPrevAssignments:    map[topicPartitionAssignment]consumerGenerationPair{},
 		},

client_tls_test.go

@@ -33,12 +33,12 @@ func TestTLS(t *testing.T) {
 	nva := time.Now().Add(1 * time.Hour)
 
 	caTemplate := &x509.Certificate{
-		Subject:               pkix.Name{CommonName: "ca"},
-		Issuer:                pkix.Name{CommonName: "ca"},
-		SerialNumber:          big.NewInt(0),
-		NotAfter:              nva,
-		NotBefore:             nvb,
-		IsCA:                  true,
+		Subject:      pkix.Name{CommonName: "ca"},
+		Issuer:       pkix.Name{CommonName: "ca"},
+		SerialNumber: big.NewInt(0),
+		NotAfter:     nva,
+		NotBefore:    nvb,
+		IsCA:         true,
 		BasicConstraintsValid: true,
 		KeyUsage:              x509.KeyUsageCertSign,
 	}

mockresponses.go

@@ -815,21 +815,21 @@ func (mr *MockListAclsResponse) For(reqBody versionedDecoder) encoder {
 	res.Err = ErrNoError
 	acl := &ResourceAcls{}
 	if req.ResourceName != nil {
-	    acl.Resource.ResourceName = *req.ResourceName
+		acl.Resource.ResourceName = *req.ResourceName
 	}
 	acl.Resource.ResourcePatternType = req.ResourcePatternTypeFilter
 	acl.Resource.ResourceType = req.ResourceType
 	host := "*"
 	if req.Host != nil {
-	    host = *req.Host
+		host = *req.Host
 	}
 	principal := "User:test"
 	if req.Principal != nil {
-	    principal = *req.Principal
+		principal = *req.Principal
 	}
 	permissionType := req.PermissionType
 	if permissionType == AclPermissionAny {
-	    permissionType = AclPermissionAllow
+		permissionType = AclPermissionAllow
 	}
 	acl.Acls = append(acl.Acls, &Acl{Operation: req.Operation, PermissionType: permissionType, Host: host, Principal: principal})
 	res.ResourceAcls = append(res.ResourceAcls, acl)