add selective support for either kafka or redis
formatting, adapt to new message format