Что вы имеете в виду "Если размер файла превышает 50 МБ, я звоню производителю kafka и передаю список идентификаторов в качестве значения"?Все, что вам нужно сделать, - это написать производителя Kafka для отправки данных в кластер Kafka и потребителя Kafka для извлечения записей из кластера Kafka и последующей записи в файл на диске.
Поскольку вы используете Spring Boot для своего проекта, вы можете использовать методы запросов в своем классе репозитория для извлечения данных из базы данных, проходите через уровень обслуживания, после чего производитель Kafka выполнит свою работу.В вашем потребителе Kafka вам просто нужно использовать записи, используя аннотацию @KafkaListener Spring Kafka.Так много примеров кодов вы можете найти с помощью нескольких поисковых запросов Google.