無名

2 声望

人生能有几回搏。

人生能有几回搏。

个人动态

发表了 kafka视频1  
7天前
無名 在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天前
neyzoter. 赞了 在 MessageRespDTO(messageRespDTOs=[]) 的评论! · 8月前

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

11月前
赞了 kafka中文教程 · 1年前
发表了 Helm入门指南  
1年前
半兽人 关注了Ta · 1年前
订阅了 kubernetes 主题! · 1年前
贬了 Never regretMessageRespDTO(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 Broker配置 · 4年前
赞了 开始学习kafka · 4年前