[KAFKA] Adding new client code