Add stream support over flow connection reducing metadata sent in each request for consumers and producers.