A package to comunicate with a Kafka server and lets the user control the flow of message pipeline to control success and failure on message synchronization.
