Я использую Kinesis для использования потока внутри приложения Spring Boot. Для этого я использую KCL, предоставленный AWS, и для его запуска вы определяете экземпляр Kinesis com.amazonaws.services.kinesis.clientlibrary.lib.worker.Worker и вызываете для него .run(). Я не хочу использовать пружинную интеграцию для этой задачи.
Я хочу построить здесь абстракцию, чтобы разработчики могли создавать несколько рабочих и запускать их автоматически во время или после запуска приложения, а затем вызывать соответствующий .shutdown() метод на прекращение заявки. Сейчас я делаю это, создавая @Component для каждого работника, а затем run() на @PostConstruct и @PreDestroy.
Есть ли лучший способ?