We have rest-api based java service (spring REST application in Tomcat server), which is basically handling the CRUD operation against the database. Now we have a requirement to consume some kafka events to update few tables.