Fix for SubscribeForMetadata in the kafka client mock.
(No longer panics when called.)
VOL-2207
Change-Id: I45e506d2ccdce1b44a44cb91f5dc7b6b3d655e7b
diff --git a/VERSION b/VERSION
index 818bd47..2451c27 100644
--- a/VERSION
+++ b/VERSION
@@ -1 +1 @@
-3.0.6
+3.0.7
diff --git a/pkg/mocks/kafka_client.go b/pkg/mocks/kafka_client.go
index 62af5db..38f147e 100644
--- a/pkg/mocks/kafka_client.go
+++ b/pkg/mocks/kafka_client.go
@@ -112,7 +112,7 @@
}
func (kc *KafkaClient) SubscribeForMetadata(_ func(fromTopic string, timestamp int64)) {
- panic("unimplemented")
+ logger.Debug("SubscribeForMetadata - unimplemented")
}
func (kc *KafkaClient) Send(msg interface{}, topic *kafka.Topic, keys ...string) error {
@@ -137,9 +137,11 @@
}
func (kc *KafkaClient) EnableLivenessChannel(enable bool) chan bool {
+ logger.Debug("EnableLivenessChannel - unimplemented")
return nil
}
func (kc *KafkaClient) EnableHealthinessChannel(enable bool) chan bool {
+ logger.Debug("EnableHealthinessChannel - unimplemented")
return nil
}