use core async to combine kafka streams