Made another interface for kafka communication, unit tests pass!!