Невозможно использовать сообщения с помощью python-kafka

Я пытался воспроизвести шаги, описанные в блоге. . При попытке получить код Python Kafka Consumer и Kafka Producer я могу запустить код в интерактивном терминале Python, а консоль потребителя дает вывод, но если я передам их в файл Python (*.py), он ничего не потребляет.

Потребитель

from kafka import KafkaConsumer
consumer = KafkaConsumer('sample')
for message in consumer:
    print (message)

Режиссер

from kafka import KafkaProducer
producer = KafkaProducer(bootstrap_servers='localhost:9092')
producer.send('sample', b'Hello, World!')
producer.send('sample', key=b'message-two', value=b'This is Kafka-Python')

Как я могу заставить его работать в файле python?