添加链接 注册    登录
link之家
链接快照平台
  • 输入网页链接，自动生成快照
  • 标签化管理网页链接
相关文章推荐
冷静的牛肉面  ·  python数据分析与挖掘论文_《Pytho ...·  1 年前    · 
叛逆的松鼠  ·  细说 MySQL 创建表的三种方法 - 掘金·  1 年前    · 
link之家  ›  解决：Kafka 报错 java.io.IOException: Can‘t resolve address: iZuf65paliafsmaw29vb8jZ:9092_CrazySnail_x的博客
kafka apache 科技新闻 消息队列
https://blog.csdn.net/weixin_40910372/article/details/107983148
气势凌人的洋葱
1 年前

今天在自己的服务器上装了一个Kafka，在自己电脑上使用springboot集成kafka，发送消息的时候，报了下面的错误： 

[customer] 2020-08-13 16:23:32.984 WARN  [kafka-producer-network-thread | producer-1] [NetworkClient                 ] [Producer clientId=producer-1] Error connecting to node iZuf65paliafsmaw29vb8jZ:9092 (id: 0 rack: null)java.io.IOException: Can't resolve address: iZuf65paliafsmaw29vb8jZ:9092
	at org.apache.kafka.common.network.Selector.doConnect(Selector.java:235)
	at org.apache.kafka.common.network.Selector.connect(Selector.java:214)
	at org.apache.kafka.clients.NetworkClient.initiateConnect(NetworkClient.java:864)
	at org.apache.kafka.clients.NetworkClient.ready(NetworkClient.java:265)
	at org.apache.kafka.clients.producer.internals.Sender.sendProducerData(Sender.java:266)
	at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:238)
	at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:163)
	at java.base/java.lang.Thread.run(Thread.java:835)
Caused by: java.nio.channels.UnresolvedAddressException: null
	at java.base/sun.nio.ch.Net.checkAddress(Net.java:130)
	at java.base/sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:675)
	at org.apache.kafka.common.network.Selector.doConnect(Selector.java:233)
	... 7 common frames omitted
 - org.apache.kafka.clients.NetworkClient - NetworkClient.java:873
java.io.IOException: Can't resolve address: iZuf65paliafsmaw29vb8jZ:9092
	at org.apache.kafka.common.network.Selector.doConnect(Selector.java:235)
	at org.apache.kafka.common.network.Selector.connect(Selector.java:214)
	at org.apache.kafka.clients.NetworkClient.initiateConnect(NetworkClient.java:864)
	at org.apache.kafka.clients.NetworkClient.ready(NetworkClient.java:265)
	at org.apache.kafka.clients.producer.internals.Sender.sendProducerData(Sender.java:266)
	at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:238)
	at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:163)
	at java.base/java.lang.Thread.run(Thread.java:835)
Caused by: java.nio.channels.UnresolvedAddressException: null
	at java.base/sun.nio.ch.Net.checkAddress(Net.java:130)
	at java.base/sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:675)
	at org.apache.kafka.common.network.Selector.doConnect(Selector.java:233)
	... 7 common frames omitted

从报错内容中可以看到，是因为无法解析 iZuf65paliafsmaw29vb8jZ 这个地址造成的，那么我们只需要在hosts文件中添加： 

101.130.125.17 iZuf65paliafsmaw29vb8jZ

Mac中hosts文件路径：/private/etc/hosts，如果提示没有权限，则将hosts复制出来，修改完了再粘贴过去覆盖就好啦。

101.130.125.17是我的服务器的地址，iZuf65paliafsmaw29vb8jZ是报错里无法解析的地址。

改完之后再试一次就OK啦！

今天在自己的服务器上装了一个Kafka，在自己电脑上使用springboot集成kafka，发送消息的时候，报了下面的错误：[customer] 2020-08-13 16:23:32.984 WARN [kafka-producer-network-thread | producer-1] [NetworkClient ] [Producer clientId=producer-1] Error connecting to node iZuf65paliafsmaw
本文，Verisign实验室大规模数据分析基础设施的技术主管Michael通过示例对 Kafka 整合到SparkStreaming进行了详细讲解，更分享了该领域的现状和一些注意点。作者MichaelG.Noll是瑞士的一位工程师和研究员，效力于Verisign，是Verisign实验室的大规模数据分析基础设施（基础Hadoop）的技术主管。本文，Michael详细的演示了如何将 Kafka 整合到SparkStreaming中。期间， Michael还提到了将 Kafka 整合到SparkStreaming中的一些现状，非常值得阅读，虽然有一些信息在Spark1.2版本中已发生了一些变化，比如HA策略：
Kasocki是一个实验项目，用于通过Socket. io 服务器公开 Kafka 消息。 该项目已被Wikimedia EventStreams取代，后者使用SSE协议代替。 另请参阅 。
使用Netty采集 Kafka 的数据 使用 Java Netty构建一个HTTP服务器，该服务器接受一个JSON对象并将其保存到 Kafka 队列中。 为此，请在开发机器上设置netty / kafka 。 需要 Java 和Maven的有效安装。 基于： : Apache Kafka 初始化 步骤1：下载程式码 wget http://ftp.halifax.rwth-aachen.de/apache/ kafka /2.3.0/ kafka _2.12-2.3.0.tgz tar -xzf kafka _2.12-2.3.0.tgz cd kafka _2.11-1.0.1 步骤2：启动ZooKeeper服务器 bin/zookeeper-server-start.sh config/zookeeper.properties 步骤3：启动 Kafka 服务器： bin/ kafka -server-st
使用 Docker 在本地运行 docker build -t angular-websocket- kafka . docker run -p 3000:3000 -d angular-websocket- kafka 该应用程序现在应该在localhost:3000上运行，或者如果您在 boot2docker IP 地址的端口 3000 上使用 boot2docker（运行boot2docker ip以找到它）。 部署到 CoreOS fleetctl start angular-webs
kafka -connect-zeebe 这个适用于器可以做两件事： 当工作流实例达到特定活动时，将消息发送到 Kafka 主题。 请注意，一条message更确切地说是一个卡夫卡record ，通常也称为event 。 这是 Kafka Connect演讲中的消息来源。 消耗来自 Kafka 主题的消息，并将它们与工作流程相关联。 这是一个 Kafka Connect接收器。 它可以与或独立的Zeebe经纪人合作。 有关实现的一些背景，请参。 示例和演练 以下视频引导您完成连接的示例： 安装和快速入门 您将在此处找到有关如何构建连接器以及如何运行 Kafka 和Zeebe的信息，以快速入门： 该插件带有两个连接器，即源连接器和接收器连接器。 源连接器激活Zeebe作业，将其发布为 Kafka 记录，并在将它们提交给 Kafka 后完成。 水槽连接器 在工作流模型中，您可以按名称等待某些事件（通
阿里云上 部署 Kafka 启动 报错 java . io . IOException : Can't resolve address . 本地调试的, 报错 需要在本地添加阿里云主机的 host 映射 linux kafka server 192.168.0.141 hostnamebogon 在windows java 代码 package myzookeeper; impo...
at java .lang.Thread.run(Thread. java :748) [na:1.8.0_272] Caused by: java .n io .channels.Un resolve d Address Except io n: null at sun.n io .ch.Net.check Address (Net. java :104) ~[na:1.8.0_272 错误如下： 1. java . io . IOException : Can’t resolve address : kafka 2:9093 2.Except io n thrown when sending a message with key=‘null’ and payload=‘37’ to topic product: 解决 方法 在你的本机中 /etc/hosts文件中 加入 kafka 的映射地址
这个错误是 Kafka 出现的一个异常情况，意味着程序在运行过程中被强制中断了。具体来说，是由于程序在等待某个操作完成时，被外部因素（比如操作系统）强制中断了，导致程序无法正常完成该操作并抛出该异常。这个异常通常会在 Kafka 客户端的使用中出现，比如在数据消费者的消费过程中。 解决 该错误需要找到导致程序被中断的具体原因。可能的原因包括操作系统资源耗尽、网络连接不稳定等等。一些具体的 解决 方案可能包括增加操作系统资源、优化程序代码、尝试连接其他网络等等。总之，这个异常提示需要我们注意程序在运行过程中可能会出现的问题，及时处理并改进程序的运行方式。
springboot报ScannerException：character ‘@‘ that cannot start any token. (Do not use @ for indentation sqlserver2019736: 并发，并行与串行的区别 识时务者914: 可以写详细一些
 
推荐文章
冷静的牛肉面  ·  python数据分析与挖掘论文_《Python数据分析与机器学习实战-唐宇迪》读书笔记第10章-特征工程..._weixin_39616477的博客-CSDN博客
1 年前
叛逆的松鼠  ·  细说 MySQL 创建表的三种方法 - 掘金
1 年前
今天看啥   ·   Py中国   ·   codingpro   ·   藏经阁   ·   小百科   ·   link之家   ·   卧龙AI搜索
删除内容请联系邮箱 2879853325@qq.com
link之家 - 链接快照平台
© 2024 ~ 沪ICP备11025650号