Fix test

banzaicloud · Jun 9, 2022 · fc1da37 · fc1da37
1 parent cbd7bac
commit fc1da37
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/pkg/resources/kafka/configmap_test.go b/pkg/resources/kafka/configmap_test.go
@@ -25,10 +25,11 @@ import (
 	"github.com/banzaicloud/koperator/pkg/util"
 	kafkautils "github.com/banzaicloud/koperator/pkg/util/kafka"
 
-	properties "github.com/banzaicloud/koperator/properties/pkg"
-
 	"github.com/banzaicloud/koperator/api/v1beta1"
 	"github.com/banzaicloud/koperator/pkg/resources"
+	mocks "github.com/banzaicloud/koperator/pkg/resources/kafka/mocks"
+	properties "github.com/banzaicloud/koperator/properties/pkg"
+	"github.com/stretchr/testify/mock"
 )
 
 func TestGetMountPathsFromBrokerConfigMap(t *testing.T) {
@@ -469,8 +470,11 @@ zookeeper.connect=example.zk:2181/`,
 		test := test
 
 		t.Run(test.testName, func(t *testing.T) {
+			mockClient := new(mocks.Client)
+			mockClient.On("Get", mock.Anything, mock.Anything, mock.Anything).Return(nil)
 			r := Reconciler{
 				Reconciler: resources.Reconciler{
+					Client: mockClient,
 					KafkaCluster: &v1beta1.KafkaCluster{
 						ObjectMeta: metav1.ObjectMeta{
 							Name:      "kafka",