無名

2 声望

人生能有几回搏。

人生能有几回搏。

个人动态

发表了 kafka视频1  
7天前
半兽人 赞了 無名 的 Html5新增了27个元素 · 12天前
俊俏的俊 回复 無名 在 启动kafka的时候 测试消息是否可以正常发送报错 java.net.UnknownHostException: home 中 ：

非常感谢

25天前
俊俏的俊 回复 無名 在 在linux服务器启动kafka报错INFO Got user-level KeeperException when processing sessionid:0x1004d84dd0d0000 中 ：

非常感谢(^o^)／

25天前
無名 在 在linux服务器启动kafka报错INFO Got user-level KeeperException when processing sessionid:0x1004d84dd0d0000 发表评论：

info级别的日志，属于正常输出可以忽视。

25天前
無名 在 启动kafka的时候 测试消息是否可以正常发送报错 java.net.UnknownHostException: home 发表评论：

home解析不开，怀疑localhost有问题。
你试试

./kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic cruise_topic
25天前
無名 在 kafka客户端 - java 发表评论：

博主代码功底深厚啊！

26天前
赞了 Html5新增了27个元素 · 27天前
無名 赞了 無名 的 Html5新增了27个元素 · 27天前
知恩图报 赞了 無名 的 kafka生产者Java客户端 · 5月前
Lance.Wu 赞了 無名 的 Html5新增了27个元素 · 6月前
燕子坞 赞了 無名 的 kafka生产者Java客户端 · 6月前
neyzoter. 赞了 在 MessageRespDTO(messageRespDTOs=[]) 的评论! · 8月前

不影响的，如果你异步发送，阻塞也是异步阻塞的，不会涉及到主线程的。并且是当ack=all的时候，才会异步阻塞。

发表了 Html5新增了27个元素  
11月前
发表了 linux自定义一个消耗内存的小程序(以Mb为单位)  
1年前
赞了 kafka中文教程 · 1年前
半兽人 赞了 無名 的 kafka的生态系统 · 1年前
发表了 Helm入门指南  
1年前
半兽人 关注了Ta · 1年前
订阅了 kubernetes 主题！ · 1年前
赞了 对于消息队列功能，kafka和zookeeper哪个版本较为稳定？ · 1年前
贬了 Never regret 在 MessageRespDTO(messageRespDTOs=[]) 的评论! · 1年前

您好，我在windows环境写了简单的producer，跟您上面给的例子一样，运行也没有报错，但是在虚拟机linux里的kafka自带的consumer消费不到，listener也设置了虚拟机的ip端口，请问是哪里出了问题呢？

关注了用户 C`c · 1年前
C`c 关注了Ta · 1年前
发表了 JsTree和ZTree对比  
1年前
赞了 我是一个线程 · 2年前
赞了 kafka命令大全 · 2年前
订阅了 kafka 主题！ · 2年前
赞了 kafka客户端 - java · 2年前
Explore 关注了Ta · 2年前
关注了用户 半兽人 · 2年前
赞了 kafka启动后，关掉控台后，集群就挂了 · 4年前
赞了 Kafka Broker配置 · 4年前
赞了 开始学习kafka · 4年前