是否可以有一个Kafka Streams应用程序，该应用程序运行主题中的所有数据然后退出？
示例我正在根据日期将数据生成到主题中。消费者开始使用cron，浏览所有可用数据，然后..做什么？我不想让它坐下来等待更多数据。只需假设所有内容都存在，然后正常退出即可。
可能的？
您可以创建一个consumer，然后一旦它停止提取数据，您可以致电consumer.close()。或者，如果您希望将来再次轮询，请致电consumer.pause()并.resume稍后再致电。
一种方法是在消费者调查区中。如
data = consumer.poll()
if (!data.next()) {
consumer.close()
}
请记住，poll返回ConsumerRecord<K,V>并符合Iterable接口。
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句