@contextlib.contextmanager
  def batch(self):

    messages = []
    yield(messages)
    self.send(messages)
Send messages with an implict `send`.
dataset/ETHPy150Open harelba/tail2kafka/kafka/producer.py/Producer.batch