我需要定期读取我的 mongo DB 表数据并使用 Spring Boot 将其发布到 Kafka 主题中。我在 Mongo DB 中创建了一个集合，并在 Mongo DB 中插入了一些记录。此外，我想定期从 Mongo DB 中读取数据，并且需要使用 Spring Boot 在 Kafka 的主题中发布这些表数据。我对春季批处理调度程序很陌生。你能建议我一个实现这一目标的想法吗？
提前致谢。
【问题讨论】：
标签： mongodb spring-boot spring-batch spring-kafka
您所说的与 Spring Integration 更相关：https://spring.io/projects/spring-integration#overview
因此，您配置了 MongoDbMessageSource 和 Poller 以定期读取集合。
然后你有基于KafkaProducerMessageHandler 的服务激活器来将数据抑制到 Kafka 主题中。
在文档中查看更多信息：
https://docs.spring.io/spring-integration/docs/5.3.2.RELEASE/reference/html/mongodb.html#mongodb
https://docs.spring.io/spring-integration/docs/5.4.0-M3/reference/html/kafka.html#kafka
不确定如何使用 Spring Batch 执行此操作...
【讨论】：