小编sms*_*190的帖子

我在ec2实例上运行kafka.因此,amazon ec2实例有两个ips,一个是内部ip,第二个是外部使用.

我从本地机器创建了生产者,但它重定向到内部ip并给我连接失败错误.任何人都可以帮我在ec2实例上配置kafka,这样我就可以从本地机器运行生产者了.我尝试了很多组合,但没有奏效.

我编写了一个程序来将项目写入DynamoDB表.现在我想使用PySpark读取DynamoDB表中的所有项目.在Spark中有没有可用的库？