SCS Kafka 消费者仅处理最新消息

SCS Kafka consumer processing only latest messages

我正在使用 SCS 1.3。0.RELEASE。我有一个生产者和一个消费者应用程序。在没有启动消费者应用程序的情况下,我使用生产者应用程序发送了一些消息。然后启动消费者应用程序但消息未被消费。当两者都启动时,消费者应用程序正在正确处理。

如果消费者没有spring.cloud.stream.<...>.group属性,默认会在话题结束时开始消费

添加群组。