Conflune kafka 5.0.0已安装在aws ec2上，其公共ip地址为54.xx.xx.xx，在ec2机器上以0.0.0.0打开端口9092
在/etc/kafka/server.properties中，我已经公布了.listeners=plaintext://54.xx.xx.xx：9092和侦听器=plaintext://0.0.0.0：9092在/etc/kafka/producer.properties中我有bootstrap.servers=0.0.0.0:9092
本地文件iotstatesboto.py已编写如下，它具有汇合生产者代码：

from confluent_kafka import Producer
import json

broker = '54.XX.XX.XX'
topic = 'mytopic'

def delivery_report(err, msg):
    if err is not None:
        print('Message delivery failed: {}'.format(err))
    else:
        print('Message delivered to {}'.format(msg.topic()))

def lambda_handler(event, context): 
    p = Producer({'bootstrap.servers': broker})
    message = json.dumps(event)
    print(message)
    p.produce(topic, message.encode('utf-8'), callback=delivery_report)
    return { 
        'message' : message
    }

本地制作的邮政包如下：

pip install confluent_kafka has been done in the same directory
zip -r iotstatesboto.zip iotstatesboto.py confluent*

此zip文件上载到lambda函数。当“test”函数发送一个伪消息时，会出现以下错误
第一：

{
  "errorMessage": "Unable to import module 'iotstatesboto'"
}

还有一个是：

Unable to import module 'iotstatesboto': No module named 'confluent_kafka.cimpl'

我已将处理程序名称设置为“iotstatesboto.lambda\u handler”
从lambda函数获取producer以写入ec2上的kakfa流，这些步骤中可能缺少什么线索？