kafka- python тайм-аут, когда производитель отправляет сообщение в topi c в docker контейнере

Question

1. У меня есть три хоста kafka, которые работают на реальных хостах;
2. Я хочу отправить msg на kafka в контейнере docker, этот контейнер может подключаться к хостам kafka;
3. Когда я отправляю сообщение в docker, контейнер использует kafka- python, всегда принимается ошибка тайм-аута, например:

  File "/usr/local/lib/python3.6/dist-packages/kafka/producer/future.py", line 65, in get
    raise self.exception # pylint: disable-msg=raising-bad-type
kafka.errors.KafkaTimeoutError: KafkaTimeoutError: Batch for TopicPartition(topic='online_model_msg', partition=0) containing 1 record(s) expired: 46 seconds have passed since batch creation plus linger time

Доза sb знает, как это исправить?