今天在学习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发送消息失败相关推荐

  1. Kafka 发送消息失败

    在使用brew services start kafka 成功启动kafka后, 执行发送消息会有提示以下,无法发送消息. kafka-console-producer --broker-list l ...

  2. 物联网架构----EMQ-Hook了解、连接Kafka发送消息

    物联网架构----EMQ-Hook了解.连接Kafka发送消息 1. 前言 按照我自己设计的物联网框架,对于MQTT集群中的所有消息,是要持久化到磁盘的,这里采用一个消息队列中间件Kafka作为数据缓 ...

  3. RabbitMQ消息队列,发送消息失败、消息持久化、消费者失败处理方法和发送消息

    项目是使用springboot项目开发的,前是代码实现,后面有分析发送消息失败.消息持久化.消费者失败处理方法和发送消息解决方法及手动确认的模式 先引入pom.xml <!--rabbitmq- ...

  4. kafka发送消息的三种方式

    1.发后即忘(fire-and-forget) 只管往kafka发送消息而并不关心消息是否正确到达.正常情况没什么问题,不过有些时候(比如不可重试异常)会造成消息的丢失.这种发送方式性能最高,可靠性最 ...

  5. springboot kafka发送消息

    场景:kafka发送消息,并且根据消息发送的不同渠道和消息类型(例如发送到WX,DingDing,邮箱),采取不同的线程池处理 1.引入依赖 <dependency><groupId ...

  6. AfxWnd42 qq2006中怎样取得发送消息窗口中的Richedit

    qq2006中怎样取得发送消息窗口中的Richedit 2006-11-10 02:20hzp997 | 分类:Windows | 浏览1695次 学习编程中想让程序可以自动在QQ的发送消息框中自动发 ...

  7. netty心跳过程中 发送消息失败_netty心跳机制和断线重连(四)

    心跳是为了保证客户端和服务端的通信可用.因为各种原因客户端和服务端不能及时响应和接收信息.比如网络断开,停电 或者是客户端/服务端 高负载. 所以每隔一段时间 客户端发送心跳包到客户端  服务端做出心 ...

  8. kafka创建topic_Kafka系列第三篇!10 分钟学会如何在 Spring Boot 程序中使用 Kafka 作为消息队列?...

    Guide哥答应大家的 Kafka系列的第3篇原创文章,写的非常详细,没有接触过 Kafka 的朋友应该都可以看懂,觉得不错的话一定要点亮你们的在看!在看就是对Guide 哥最大的鼓励! 为了保证内容 ...

  9. Kafka 发送消息

    – Start 点击此处观看本系列配套视频 在上个例子中,我们使用了脚本来发送消息,来吧,让我们来自己写点代码来发送消息.首先还是按照上个例子,先启动 ZooKeeper 和 启动 Kafka bor ...

最新文章

  1. 运维工具SaltStack
  2. 树莓派:树莓派的刷机和登录,以及更新新版vim方便使用
  3. sgi allocate
  4. Python科学计算:Pandas
  5. 用Python制作一个随机抽奖小工具
  6. 一份 2.5k star 的《React 开发思想纲领》
  7. 第七季4:网络telnet调试、海思proc文件系统调试接口
  8. java json u0026_特殊字符的json序列化
  9. 电商库存详解:三层(销售层、调度层、仓库层)来看库存设计
  10. 信息学奥赛一本通(1397:简单算术表达式求值)
  11. 程序安装制作不用愁—Wise installation入门教程
  12. 2021 M1 iMac 的 8 个最佳功能
  13. 小学信息技术了解计算机课件,小学信息技术《走进计算机》ppt课件
  14. Storage System
  15. TQ2440开发板移植UBOOT-2010.06总结(3)
  16. 1024网易程序员节,最上头的爱,给最好的你!
  17. 如何为您的Android手机创建自定义铃声
  18. SecureCRT常用文件操作命令
  19. 双亲委派模型和破坏性双亲委派模型详解
  20. 计算机理论导引 试卷,计算机理论导引实验报告_CFG是P成员.doc

热门文章

  1. Angr Manual
  2. Motoman机器人离线编程——MotocomES介绍
  3. Linux内核编译很简单,6步编译一个自己的内核
  4. 外贸客户开发误解,网上很多看似专业的理论并不切实际
  5. 机器学习——大规模机器学习
  6. SNS游戏-使用Json作为缓存数据格式
  7. android 纵向抽屉,Android导航抽屉垂直边框
  8. 读书笔记:《敏捷估计与规划》
  9. [PADS经验] 【图文并茂】教你如何使用Altium Designer画封装
  10. 使用 Navicat 代码段