Почему мой продюсер останавливается... может "произвести" только одно сообщение

Question

Я написал программу продюсера pykafka. Программа запрашивает базу данных и вызывает метод для создания сообщения для kafka. Проблема в том, что первое сообщение отправляется нормально. Однако, когда он пытается отправить второе сообщение, я получаю исключение "ProducerStoppedException". По сути, у меня есть класс, созданный для работы с кафкой. Это выглядит примерно так:

from pykafka import KafakClient

class myKafka(object):
   def __init__(self, host, topic):
      self.client = KafkaClient(hosts=host)
      self.topic = topic
      self.producer = self.topic.get_producer()

   def send_message(self, message):
      with self.producer as producer
         send_result = self.produer.produce(message)

Из моего класса вызовов я вызываю send_message несколько раз... один раз для каждого сообщения, которое я хочу отправить. Мне не ясно, почему продюсер "останавливается".