kafka producer and consumer support in riemann