反应式管道的优雅终止

问题描述

在调用 disposable.dispose() 后完成正在进行的事件处理的最佳方法是什么？我有一个从 Kafka 消费并在容器中运行的应用程序。我想注册一个 JVM 关闭挂钩来取消该订阅并正常终止流（仅在处理任何正在进行的事件后才终止它）。

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）