在将消息写入kafka spring boot之前等待kafka消费者轮询

Question

我有以下问题。 我想启动一个从kafka读写的spring boot应用程序 使用@KafkaListener。

我想：

1. 将 kafka 消费者初始化为最新的偏移量。
2. 向 kafka 写消息
3. 然后使用在步骤 1 中创建的消费者从 kafka 读取这些消息

我面临以下问题第 2 步有时会在 kafka 消费者有时间执行第一次 poll() 操作之前运行。 这意味着它会忽略这些消息，因为它会在最晚之前考虑它们。

在使用 spring-kafka 时是否有保证消费者在应用程序启动之前轮询。

Answer 1

通常，在同一个应用程序中拥有 producer 和 consumer 是错误的架构。因此，确实不能保证其中一个在另一个开始工作时存在。

无论如何，您的应用程序有一个技巧可以尽可能晚地开始生成。

为此，您需要考虑实现SmartLifeCycle 并将用于发送的逻辑逻辑放入其start() 实现中。