我正在尝试从twitter流式传输数据并存储在一个主题中。我使用的是单代理，所有的东西都是在一台服务器上设置的。我正在使用ec2示例并进行配置 listeners = PLAINTEXT://aws_private_ip:9092 以及 advertised.listeners=PLAINTEXT://aws_private_ip:9092 ，尝试从ec2示例发送和接收消息时，一切正常。
但是，当我尝试从本地窗口运行producer来流式传输twitter数据时，我遇到了以下错误：
线程“main”kafka.common.failedtosendmessageexception中出现异常：尝试3次后发送消息失败
我错过什么了吗？我可以用2181和9092端口从本地系统远程登录到ec2示例。我需要在任何地方配置公共ip吗？
注意：在我的本地ubuntu vm中，相同的生产者和消费者代码按预期运行，但是在使用aws ec2时出现上述错误。我打开了所有的安全组端口。