Kafka Stream: 优雅关闭

Question

Kafka Stream: 优雅关闭

apache-kafkaapache-kafka-streams

3

如果我们在后台启动KafkaStream应用程序（例如Linux），是否有一种方法可以从外部向应用程序发出信号，以启动优雅的关闭？

- Raman

1个回答

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- Matthias J. Sax · Accepted Answer

如文档所述（https://kafka.apache.org/11/documentation/streams/tutorial），建议注册一个关闭挂钩，以调用KafkaStreams#close()进行干净的关闭：

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);