Merge pull request #172 from VladoLavor/dev

fixed kafka statuscheck
ligato · Sep 26, 2017 · 9b5e162 · 9b5e162
2 parents d80416b + 51fbeac
commit 9b5e162
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/messaging/kafka/plugin_impl_kafka.go b/messaging/kafka/plugin_impl_kafka.go
@@ -111,7 +111,7 @@ func (plugin *Plugin) AfterInit() error {
 	// Register for providing status reports (polling mode)
 	if plugin.StatusCheck != nil && !plugin.disabled {
 		plugin.StatusCheck.Register(plugin.PluginName, func() (statuscheck.PluginState, error) {
-			if plugin.mux.Consumer == nil || plugin.mux.Consumer.Client == nil {
+			if plugin.hsClient == nil || plugin.hsClient.Closed() {
 				return statuscheck.Error, fmt.Errorf("kafka client/consumer not initialized")
 			}
 			// Method 'RefreshMetadata()' returns error if kafka server is unavailable