我在kafka中使用了一个压缩的主题,该主题在应用程序启动时加载到HashMap中。然后,我正在听一个普通的消息主题,并使用从压缩的主题构造的HashMap处理它们。
在开始收听其他主题之前,如何确保完全阅读压缩主题并完全初始化HashMap?(与RestControllers相同)
在中实施SmartLifecycle并加载地图start()。确保phase早于需要地图的任何其他对象。
SmartLifecycle
start()
phase