'Establish connection used for producing.
See Also:
:meth:`connection` for supported arguments.'

def connection_for_write(self, url=None, **kwargs):

    return self._connection((url or self.conf.broker_write_url), **kwargs)
