Get rid of shutdown hook, as it might interfere with static membership.
@@ -371,12 +371,4 @@ public class FastenKafkaPlugin implements FastenServerPlugin {
return statusRecords;
}
-
- /**
- * Add hook for graceful consumer shutdown.
- */
- private void handleConsumerShutdown() {
- Thread closeConsumer = new Thread(() -> connection.close());
- Runtime.getRuntime().addShutdownHook(closeConsumer);
- }
}
