如何在启动上下文之前在内存中加载压缩的主题 [英] How to load a compacted topic in memory before starting the context

问题描述

我使用的是Kafka中的压缩主题，在应用程序启动时将其加载到HashMap中。 然后，我监听消息的普通主题，并使用从压缩的主题构造的HashMap来处理它们。

在开始收听其他主题之前，如何确保压缩的主题已完全阅读且HashMap已完全初始化？ (RestController相同)

推荐答案

实现SmartLifecycle，将地图加载到start()中。请确保phase早于任何其他需要映射的对象。

这篇关于如何在启动上下文之前在内存中加载压缩的主题的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！