kaffe
kaffe copied to clipboard
Support custom client_name in all public functions
Hi,
I've implemented new public functions to accept the client_name as parameter and a new function to stop the client to a given client_name.
It's useful to switch the Kafka cluster in runtime. In order to do it I need to start a new client to the new endpoint, produce the events to the new client and then stop the old client.