私はカフカが初めてです。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 ループ コードの実行がスタックしていて、私には理解できないことです。