initial support for consumer, producer and mirror kafka roles