python - メッセージを受信すると、python pulsar コンキュマーがブロックされます

Question

私のアプリケーションには、2 つの Python スクリプト producer.py と consumer.py があります。

# producer.py
client = pulsar.Client("pulsar://localhost:6650")
producer = client.create_producer("topic1")
producer.send(pickle.dumps(obj))

producer = client.create_producer("topic2")
producer.send(pickle.dumps(obj))

# consumer.py
client = pulsar.Client("pulsar://localhost:6650")
consumer = client.subscribe("topic1", "sub1")
msg = consumer.receive()
consumer.acknowledge(msg)
data = msg.data()

consumer = client.subscribe("topic2", "sub2")
msg = consumer.receive()
consumer.acknowledge(msg)
data = msg.data()

producer.py は 2 つのトピックを生成し、consumer.py は 2 つのトピックをサブスクライブします (トピック名は実行ごとに変更されます)。最初に Producer.py を起動すると、コンシューマーは何も受信できず、プロセスがブロックされます。最初に consumer.py を起動し、次に Producer.py を起動すると、consumer は最初のトピックのデータを受信できますが、2 番目のトピックはまだ受信できません。