Pipe to send/receive messages to/from Broker.
When this resulting Stream is run, it will connect to destination broker,
then it will start to consume messages from source and send them
to given broker with kafka protocol.
In parallel this receives any messages from broker, de-serializes them
and emits them.
At any time, when the connection fails, or messages cannot be encoded/decoded
this process will fail resulting in termination of the connection with Broker.
Address of the kafka Broker
Timeout for performing the write operations