diff --git a/src/main/java/com/googlesource/gerrit/plugins/kafka/publish/KafkaPublisher.java b/src/main/java/com/googlesource/gerrit/plugins/kafka/publish/KafkaPublisher.java
index 8c78439..27dd3e7 100644
--- a/src/main/java/com/googlesource/gerrit/plugins/kafka/publish/KafkaPublisher.java
+++ b/src/main/java/com/googlesource/gerrit/plugins/kafka/publish/KafkaPublisher.java
@@ -27,7 +27,6 @@
 
   private final KafkaSession session;
   private final Gson gson;
-  private boolean available = true;
 
   @Inject
   public KafkaPublisher(
@@ -40,34 +39,20 @@
   public void start() {
     if (!session.isOpen()) {
       session.connect();
-      available = true;
     }
   }
 
   public void stop() {
     session.disconnect();
-    available = false;
   }
 
   @Override
   public void onEvent(Event event) {
-    if (available && session.isOpen()) {
+    if (session.isOpen()) {
       session.publish(gson.toJson(event));
     }
   }
 
-  public void enable() {
-    available = true;
-  }
-
-  public void disable() {
-    available = false;
-  }
-
-  public boolean isEnabled() {
-    return available;
-  }
-
   public String getName() {
     return "Kafka";
   }