I have a multi-service project that uses spring boot, apache kafka, and jpa. My project requires that no matter what I write to the database I want to send a message to a kafka topic. Therefore I have create 3 classes to increase reusability: