我希望每当我调用此函数时再次消耗特定偏移量和分区的旧kafka事件。我应该使用 Kafka Stream 还是 kafkaListner

Question

当旧事件数量较少或较多时，这是首选。我正在使用弹簧靴

Answer 1

您可以使用 KafkaListener 或 Kafka Streams，或两者都使用，因为它们都是消费者函数。

您需要将事件存储在某个地方以获取“旧”事件，例如内存中、SQLite、H2、RocksDB 等或其他外部数据库。

当您为消费者应用程序运行多个临时部署实例时，使用外部共享/网络存储会更好。