なぜカフカの消費者はフリーズしますか？

Question

マイカフカの消費者のフリーズ私は

from kafka import KafkaProducer 
producer = KafkaProducer(bootstrap_servers='127.0.0.1:9092') 
for _ in range(100): 
    producer.send('foobar', b'some_message_bytes') 
from kafka import KafkaConsumer 
consumer = KafkaConsumer('foobar') 
for msg in consumer: 
    print (1) 

トピックにメッセージをカウントした後、それは何も印刷されません。

私たちは、デフォルト、カフカのパイソン（最もカフカクライアント）によって

consumer.topics() 
{u'clickstream', u'foobar', u'wiki'} 

Answer 1

を持っているもののトピックに成功をプリントアウトすることができ、すなわち、最後のオフセットから開始するだけで新しいmesagesを読み込みます。あなたのケースで 、いずれかの最初のスタート、消費者、そしてプロデューサー、いずれかのループのためのあなたの消費者で

consumer = KafkaConsumer('foobar', auto_offset_reset ='earliest')