Search code examples
springspring-bootapache-kafkaspring-kafka

Polling the database for a new rows in database using Stored Procedure

Currently i am executing a stored procedure and sending message to Kafka.

Now I need to execute SP every 2 minutes or 5 minutes for new data .Is there any out of the box solution for spring boot ? Can Inbound Channel Adapter help?If yes any example or sample code will be appreciated.

Solution

  • See the Spring Integration Stored Procedure Inbound Channel Adapter.

    There are some samples in the intermediate folder of the Spring Integration Samples repo