diff --git a/pkg/kafka/client.go b/pkg/kafka/client.go
index 488bf9f..bda7ed9 100755
--- a/pkg/kafka/client.go
+++ b/pkg/kafka/client.go
@@ -69,4 +69,5 @@
 	Send(msg interface{}, topic *Topic, keys ...string) error
 	SendLiveness() error
 	EnableLivenessChannel(enable bool) chan bool
+	EnableHealthinessChannel(enable bool) chan bool
 }