无法从AWS Kafka群集外部生成Kafka消息
我有以下问题：
我在aws上只使用1个worker和broker节点建立了一个尽可能基本的汇合平台。
我对所有与人脉和关系网有关的事情都很敏感，所以我希望有人能帮助我
共有1个答案
问题解决了：配置广告侦听器成功了+在公司防火墙之外工作。-
-
我正在使用java API实现apache kafka producer。Apache Kafka安装在localhost上。Zookeeper也在运行，但Producer.send（）函数仍然卡在发送消息上，消息没有发布。 我已经创建了“快速消息”主题。
-
我有一个ECS集群，其中有3个EC2实例，它们都位于私有子网中。我创建了一个任务定义，使用以下环境变量运行Confluent提供的kafka-connect映像： 我在这个集群前面有一个应用程序负载均衡器，在端口8083上有一个侦听器。我已经正确地设置了目标组，以包括运行Kafka-Connect的EC2实例。因此负载均衡器应该将请求转发到集群。确实如此，但我总是得到响应。我可以ssh到EC2实例
-
https://github.com/confluentinc/cp-docker-images/blob/5.0.0-post/examples/kafka-cluster/docker-compose.yml 我已经编辑了该文件，并将选项添加到docker组合文件中，以便可以在主机之外访问它们。 我已经运行了以下命令： kafka-1、kafka-2、kafka-3的docker日志（均相同）
-
< li >我在Kubernetes集群中部署并运行了Kafka。我使用的图片来自docker hub-https://hub . docker . com/r/cloudtrackinc/kubernetes-Kafka/ < li >我的kubernetes群集中有3个kube节点。我有3个Kafka和3个zookeeper应用程序在运行，我有服务zoo1、zoo2、zoo3和kafka-1、
-
问题内容： 我在端口5000上的docker容器中运行了一个REST服务，该服务用于通过kafka主题生成消息，而该主题用尽了docker容器。 我为生产者客户端配置了以下属性：- 我已经用下面的命令开始了包含： 我还做了以下配置来宣传kafka主机和端口 尽管我尝试制作kafka主题时已进行了所有配置，但还是遇到了以下错误：- 有人可以指出实际问题在哪里吗？ 问题答案： 在现实生活中，永远都不应
-
在我的Scala(2.11)流应用程序中，我正在使用IBM MQ中的一个队列中的数据，并将其写入一个具有一个分区的Kafka主题。在使用MQ的数据之后，消息负载被拆分为3000个较小的消息，这些消息存储在字符串序列中。然后使用KafkaProducer将这3000条消息中的每一条发送到Kafka(2.x)。 你怎么发那3000条信息？ 我不能增加IBM MQ中的队列数（不在我的控制之下），也不能增