我在Kafka和 Spring 启动应用程序工作。我正在用java文件api编写一个驱动文件。文件数据在数据库中。我在应用程序中有存储库和服务层。如果文件大小大于50mb，那么我将调用kafka producer并传递一个id列表作为值。我可以调用服务方法来提取kafka消费者中的数据吗？
h79rfbju1#
你说“如果文件大小大于50mb，那么我就给Kafka制作人打电话，把一个id列表作为值传递”是什么意思？您只需编写一个kafka生产者将数据发送到kafka集群，然后编写一个kafka消费者从kafka集群中提取记录，然后写入驱动器中的文件。因为您的项目使用springboot，所以您可以使用repository类中的查询方法从数据库中提取数据，通过服务层，然后kafka producer将完成它的工作。在您的kafka消费者中，您只需要使用springkafka的@kafkalistener注解来消费记录。这么多的样本代码，你可以找到几个谷歌搜索。
1条答案
按热度按时间h79rfbju1#
你说“如果文件大小大于50mb，那么我就给Kafka制作人打电话，把一个id列表作为值传递”是什么意思？您只需编写一个kafka生产者将数据发送到kafka集群，然后编写一个kafka消费者从kafka集群中提取记录，然后写入驱动器中的文件。
因为您的项目使用springboot，所以您可以使用repository类中的查询方法从数据库中提取数据，通过服务层，然后kafka producer将完成它的工作。在您的kafka消费者中，您只需要使用springkafka的@kafkalistener注解来消费记录。这么多的样本代码，你可以找到几个谷歌搜索。