apache-kafka - 卡夫卡流 : Graceful shutdown

Question

如果我们在后台启动 KafkaStream 应用程序(比如 Linux)，是否有办法从外部向应用程序发送信号，以启动正常关闭？

Answer 1

如文档 ( https://kafka.apache.org/11/documentation/streams/tutorial ) 中所述，建议注册一个调用 KafkaStreams#close() 的关闭钩子(Hook)以实现干净关闭:

final CountDownLatch latch = new CountDownLatch(1);

// attach shutdown handler to catch control-c
Runtime.getRuntime().addShutdownHook(new Thread("streams-shutdown-hook") {
    @Override
    public void run() {
        streams.close();
        latch.countDown();
    }
});

try {
    streams.start();
    latch.await();
} catch (Throwable e) {
    System.exit(1);
}
System.exit(0);