在idea中往Kafka发送消息失败
今天在学习Kafka整合Springboot项目的时候,往Kafka发送消息,消费者一直消费不到,ip地址,端口号,防火墙的状态都没有发现问题。后来发现是因为idea没有连接到虚拟机的,一直在找本机的ip地址,但我yml里面是配的虚拟机的ip地址,所以才连接不上去。后来发现更改server.properties里面的配置,重启之后就可以了。
# The address the socket server listens on. It will get the value returned from
# java.net.InetAddress.getCanonicalHostName() if not configured.
# FORMAT:
# listeners = listener_name://host_name:port
# EXAMPLE:
# listeners = PLAINTEXT://your.host.name:9092
listeners=PLAINTEXT://xxx.xxx.xxx.xxx:9092
# Hostname and port the broker will advertise to producers and consumers. If not set,
# it uses the value for "listeners" if configured. Otherwise, it will use the value
# returned from java.net.InetAddress.getCanonicalHostName().
advertised.listeners=PLAINTEXT://xxx.xxx.xxx.xxx:9092
在idea中往Kafka发送消息失败相关推荐
- Kafka 发送消息失败
在使用brew services start kafka 成功启动kafka后, 执行发送消息会有提示以下,无法发送消息. kafka-console-producer --broker-list l ...
- 物联网架构----EMQ-Hook了解、连接Kafka发送消息
物联网架构----EMQ-Hook了解.连接Kafka发送消息 1. 前言 按照我自己设计的物联网框架,对于MQTT集群中的所有消息,是要持久化到磁盘的,这里采用一个消息队列中间件Kafka作为数据缓 ...
- RabbitMQ消息队列,发送消息失败、消息持久化、消费者失败处理方法和发送消息
项目是使用springboot项目开发的,前是代码实现,后面有分析发送消息失败.消息持久化.消费者失败处理方法和发送消息解决方法及手动确认的模式 先引入pom.xml <!--rabbitmq- ...
- kafka发送消息的三种方式
1.发后即忘(fire-and-forget) 只管往kafka发送消息而并不关心消息是否正确到达.正常情况没什么问题,不过有些时候(比如不可重试异常)会造成消息的丢失.这种发送方式性能最高,可靠性最 ...
- springboot kafka发送消息
场景:kafka发送消息,并且根据消息发送的不同渠道和消息类型(例如发送到WX,DingDing,邮箱),采取不同的线程池处理 1.引入依赖 <dependency><groupId ...
- AfxWnd42 qq2006中怎样取得发送消息窗口中的Richedit
qq2006中怎样取得发送消息窗口中的Richedit 2006-11-10 02:20hzp997 | 分类:Windows | 浏览1695次 学习编程中想让程序可以自动在QQ的发送消息框中自动发 ...
- netty心跳过程中 发送消息失败_netty心跳机制和断线重连(四)
心跳是为了保证客户端和服务端的通信可用.因为各种原因客户端和服务端不能及时响应和接收信息.比如网络断开,停电 或者是客户端/服务端 高负载. 所以每隔一段时间 客户端发送心跳包到客户端 服务端做出心 ...
- kafka创建topic_Kafka系列第三篇!10 分钟学会如何在 Spring Boot 程序中使用 Kafka 作为消息队列?...
Guide哥答应大家的 Kafka系列的第3篇原创文章,写的非常详细,没有接触过 Kafka 的朋友应该都可以看懂,觉得不错的话一定要点亮你们的在看!在看就是对Guide 哥最大的鼓励! 为了保证内容 ...
- Kafka 发送消息
– Start 点击此处观看本系列配套视频 在上个例子中,我们使用了脚本来发送消息,来吧,让我们来自己写点代码来发送消息.首先还是按照上个例子,先启动 ZooKeeper 和 启动 Kafka bor ...
最新文章
- 运维工具SaltStack
- 树莓派:树莓派的刷机和登录,以及更新新版vim方便使用
- sgi allocate
- Python科学计算:Pandas
- 用Python制作一个随机抽奖小工具
- 一份 2.5k star 的《React 开发思想纲领》
- 第七季4:网络telnet调试、海思proc文件系统调试接口
- java json u0026_特殊字符的json序列化
- 电商库存详解:三层(销售层、调度层、仓库层)来看库存设计
- 信息学奥赛一本通(1397:简单算术表达式求值)
- 程序安装制作不用愁—Wise installation入门教程
- 2021 M1 iMac 的 8 个最佳功能
- 小学信息技术了解计算机课件,小学信息技术《走进计算机》ppt课件
- Storage System
- TQ2440开发板移植UBOOT-2010.06总结(3)
- 1024网易程序员节,最上头的爱,给最好的你!
- 如何为您的Android手机创建自定义铃声
- SecureCRT常用文件操作命令
- 双亲委派模型和破坏性双亲委派模型详解
- 计算机理论导引 试卷,计算机理论导引实验报告_CFG是P成员.doc