2

私はカフカが初めてです。kafka-python のいくつかのオンライン チュートリアルの助けを借りて、次のコードを作成しました。

   from kafka import SimpleProducer, KafkaClient, KafkaConsumer
   kafka =  KafkaClient("localhost:9092")
   producer = SimpleProducer(kafka)
   producer.send_messages(b'my-topic', b'this method', b'Hello World')
   consumer = KafkaConsumer('my-topic',
                     group_id='my_group',
                     bootstrap_servers=['localhost:9092'])
   for message in consumer:
       print("%s:%d:%d: key=%s value=%s" % (message.topic, message.partition,
                                         message.offset, message.key,
                                         message.value))

しかし、問題は、その最後の for ループ コードの実行がスタックしていて、私には理解できないことです。

4

1 に答える 1