我正在使用一个带有共享回复主题的ReplyingKafkaTemplate（例如group.id是null并且组管理被禁用）。初始偏移量被设置为“latest”。
我面临以下问题：
1.我手动启动侦听器容器，这将导致一个异步操作，该操作将获取消费者的元数据。
1.我调用sendAndReceive()方法。
1.应答消息在第一步中的异步操作返回之前创建。
1.异步操作返回并将偏移量设置为1（由于“latest”），因此应答消息将被忽略。
为了解决这个问题，我需要Assert偏移量在调用sendAndReceive()方法之前被初始化。我已经寻找了一个合适的应用程序事件，但似乎没有一个合适。
是否有任何方法可以Assert使用者已经完全初始化？
这个问题与Wait for kafka consumer to poll before writing messages to kafka spring boot类似，但建议的解决方案也不能解决它（除非我误解了这个建议，否则它只能降低风险，而不能消除风险）。