在python-flask中调用kafka发送消息，消费者收不到?报错-问答-阿里云开发者社区-阿里云

首先，在没有flask的时候，我写了kafka的程序，一个生产者，一个消费者。

生产者进程，它负责读取本地的一张图片，把图片的二进制数据以消息的形式发送给kafka，代码如下：

        from kafka import KafkaProducer

        # get the binary data of a picture
        f=open('/home/seven/Pictures/fff.png','rb')
        data=f.read()
        f.close()

        # create a producer
        producer=KafkaProducer(bootstrap_servers=['localhost:9092'],key_serializer=str.encode)

        # send th binary data to kafka
        producer.send('img_msg',key="Hello,Assassin424214141",value=data)

消费者进程，它负责接收消息，并用消息内容还原出一张图片存储在磁盘上，代码如下：

        from kafka import KafkaConsumer

        # create a consumer
        consumer = KafkaConsumer('img_msg',bootstrap_servers=['localhost:9092'])

        # receive messages
        for message in consumer:
            # print the message
            print ("hello %s:%d:%d: key=%s"%(message.topic, message.partition,message.offset, message.key))
            # use the message's data to create a picture
            img_data=message.value
            outfile=open("test.png","wb")
            outfile.write(img_data)
            outfile.close()

代码比较简陋，是个测试用的原型，并且是可以跑的。

然而，我把生产者的代码放到flask（python-flask是一个web框架）中后。flask程序接收客户端的请求（客户端会上传一张图片），确实是接收到图片了，而且消息发送给kafka的时候也没有报错。但是怪异的是kafka的消费者那边却始终没有动静...

然后我做了一个极端的测试，服务端（即flask）把接收到的客户端上传的图片先写到磁盘上，再从磁盘上读取这张图片（就和一开始的测试原型是一样的逻辑，而且验证了图片是成功写到磁盘上的，即图片接收这一环节是没有问题的），然而这种情况下kafka的消费者却还是接收不到消息，如之奈何？

我接着做测试，发现一个普遍现象，无论是普通的字符串消息还是二进制的消息，只要不在flask中发送给kafka，则kafka的消费者都能收到。但是无论是什么类型的消息，只要把kafka生产者的代码放到flask中去，就会导致消费者那边啥也收不到。

有遇到同样情况的，请不吝赐教～