卡夫卡读书挂起

如何解决卡夫卡读书挂起

我正在从Kafka看书，但消费者挂了电话：

def produce(num,producer,topic_name):
    print("hello2")
    for i in range(num):
        future = producer.send('my-topic',bytearray("Hello Kayla 00","utf-8"))
        try:
            record_metadata = future.get(timeout=10)
        except KafkaError:
            log.exception()
            pass

                     # Successful result returns assigned partition and offset
        print (record_metadata.topic)
        print (record_metadata.partition)
        print (record_metadata.offset)

这是输出：

my-topic
0
256
my-topic
2
298
my-topic
1
299
my-topic
0
257
my-topic
0
258

因此，写作非常完美。此外，我对Kafka上的其他工具有了解，并且可以看到自己在写作。

问题出在消费者身上

def consume(num,consumer):
    print("WORK!!")
    for message in consumer:
        print("was here")
        print(message.value)
        if num == 0:
            consumer.close()
            break

使用者永远不会进入for循环。它只打印WORK!!并永远交上for message in consumer。

有人知道可能是什么问题吗？

这是我设置消费者和生产者的方式：

consumer = KafkaConsumer('my-topic',group_id="Bayern-Munchen",bootstrap_servers=bootstrap_servers,auto_offset_reset='latest')



 producer = KafkaProducer(bootstrap_servers=bootstrap_servers...)

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com(将#修改为@）