How to Use the Kafka Wrapper Library to Migrate to Hotel Semantic Inventions

The library itself shouldn't care that the users of this library happen to be engaged in an organization-wide migration to hotel semantic invention. That is not the business of the Kafka wrapper library. So I used a similar pattern to what a Lixar's telemetry libraries offer, which is the active support instrumentation pattern. And your application can write a couple lines of code that will pull those events from the eds table and do the thing with them.