【发布时间】：2018-05-27 22:04:54
【问题描述】：
我正在开发 kafka 和 Spring Boot 应用程序。我正在使用 java File api 编写一个文件来驱动。文件数据在数据库中。我在应用程序中有存储库和服务层。如果文件大小大于 50MB，那么我将调用 kafka 生产者并将 ID 列表作为值传递。我可以调用 Service 方法在我的 kafka Consumer 中提取数据吗？
【问题讨论】：
【发布时间】：2018-05-27 22:04:54
【问题描述】：
你是什么意思“如果文件大小大于 50MB，那么我正在调用 kafka 生产者并传递一个 ID 列表作为值”？您只需编写一个 Kafka 生产者将数据发送到 Kafka 集群，并编写一个 Kafka 消费者从 Kafka 集群中提取记录，然后写入驱动器中的文件。
因为您在项目中使用 Spring Boot，所以您可以使用存储库类中的查询方法从数据库中提取数据，通过您的服务层，然后 Kafka 生产者将完成其工作。在您的 Kafka 消费者中，您只需要使用 Spring Kafka 的 @KafkaListener 注释来消费记录。您可以通过几次 Google 搜索找到如此多的示例代码。
【讨论】：
-
如果文件大小小于 50 MB，则直接下载，否则我将生成一个作业并将其放入 kafka 队列。我想到了。我不知道对 kafka 的 Spring Boot 支持。现在我已经实现了。谢谢。