AWS上的Kafka代理-IP设置
我已经在EC2上安装了Kafka软件。我的问题是从AWS外部连接到经纪人。这一切都从内部为我工作。
因此，我可以启动代理，并且 kafka 控制台生产者和消费者都可以工作（来自同一服务器）。我有端口 2181 和 9092 打开到远程位置，朝向我想使用 producer 的位置。所以从我的开发（本地）机器.如果我做telnet 9092 - 它会连接我。如果我尝试使用Kafka控制台生产者，我会收到此错误。
< code> [2017-03-09 15:04:44，971]将消息发送到主题topic2时出现错误，关键字为空，值为5个字节，错误为:(org . Apache . Kafka . clients . producer . internals . errorloggingcallback)org . Apache . Kafka . common . errors . time out异常:主题topic2的1条记录过期:自批量创建加上逗留时间后已过去1521毫秒
我尝试了各种组合server.properties文件-键侦听器和advertised.listeners。
我真的非常感谢一些帮助...
共有1个答案
这可能是由于AWS机器的公共主机名/ip不能在AWS内使用造成的。如果是这样，您需要稍微捏造一下。需要做2件事：
-
< li >确保将< code > advertised . listeners 设置为您的私人地址 < li >在您的本地/etc/hosts中，将aws的本地主机名(例如IP-10-0-0-1 . eu-west-1 . compute . internal)绑定到公共IP
然后确保你总是只使用私人主机名。这是我许多奇怪问题的根本原因，没有给出任何日志。
-
注解 @ProxyPool 声明代理 IP 池，在爬虫对象或者爬虫项对象上声明，则请求时自动从代理 IP 池中取出代理IP 类名：\Yurun\Crawler\Module\Crawler\Annotation\ProxyPool 参数： 名称 描述 默认值 class 代理 IP 池名 args 实例化参数 method 获取 IP 的方式：random(随机)、next(下一个) 代理 IP
-
本文将讲述如何配置和启用 ip-masq-agent。 创建 ip-masq-agent 要创建 ip-masq-agent，运行下面的 kubectl 命令： kubectl create -f https://raw.githubusercontent.com/kubernetes-incubator/ip-masq-agent/master/ip-masq-agent.yaml 关于 ip-
-
http代理 <?php $http = HttpRequest::newSession(); $response = $http->proxy('127.0.0.1', 808) // 常见的http代理这样用 ->get('https://www.baidu.com/'); $content = $response->body(); // 网页源码 sock
-
Kafka在2个代理和1个Zookeeper实例中的奇怪问题，都在AWS上。每个代理都位于一个单独的可用性区域(AZ)。孤独的动物园管理员实例与其中一个代理共享AZ。我正试图模拟一种滚动重启的情况，在这种情况下，即使一个代理出现故障，我们也希望数据流向Kafka。 当另一个 AZ 代理被移除时，我能够看到向与 Zookeeper 共享 AZ 的代理平稳过渡。但是，当我删除与 Zookeeper 共
-
如何为每个WebView实例设置代理？ 这是我到目前为止所拥有的： 这会启动一个带有谷歌页面的窗口。 但是如何设置代理？不是VM系统代理，而是每个WebView窗口的代理。
-
本文向大家介绍java代理实现爬取代理IP的示例，包括了java代理实现爬取代理IP的示例的使用技巧和注意事项，需要的朋友参考一下 仅仅使用了一个java文件，运行main方法即可，需要依赖的jar包是com.alibaba.fastjson（版本1.2.28）和Jsoup（版本1.10.2） 如果用了pom，那么就是以下两个： 完整的代码如下： 以上这篇java代理实现爬取代理IP的示例就是小编