kafka通过控制台模拟消息发送和消息接收正常,但是通过javaAPI操作生产者发送消息不成功 消费者接收不到数据解决方案?
通过命令行工具(kafka-console-producer.sh和kafka-console-consumer.sh)是能够相互通信的，producer发布的信息consumer能够接收到。
但是java通过kafka-client的API写的代码始终不能跟kafka通信：java producer的消息发不出去， java comsumer也收不到任何消息。
仔细检查了下代码中IP、端口都没有写错。
解决办法
将kafka/config/server.properties文件中advertised.listeners改为如下属性：192.168.57.200是我虚拟机的IP。
改完后重启，OK了。Java端的代码终于能通信了
advertised.listeners=PLAINTEXT://192.168.57.200:9092
上面这一行代码在server.properties文件下的#开头的地方
kafka通过控制台模拟消息发送和消息接收正常,但是通过javaAPI操作生产者发送消息不成功 消费者接收不到数据解决方案?相关推荐
- 【kafka系列】kafka之生产者发送消息实践
目录 一.准备工作 二.终端命令 生产者命令 消费者命令 三.Java实践 搭建项目 异步发送-无回调 异步发送-有回调 同步发送 一.准备工作 进入实战之前先熟悉一下topic的相关命令,使用终端命 ...
- Kafka生产者发送消息的三种方式
Kafka是一种分布式的基于发布/订阅的消息系统,它的高吞吐量.灵活的offset是其它消息系统所没有的. Kafka发送消息主要有三种方式: 1.发送并忘记 2.同步发送 3.异步发送+回调函数 下 ...
- kafka 脚本发送_Kafka笔记归纳（第五部分:一致性保证，消息重复消费场景及解决方式）...
写在开头: 本章是Kafka学习归纳第五部分,着重于强调Kafka的事一致性保证,消息重复消费场景及解决方式,记录偏移量的主题,延时队列的知识点. 文章内容输出来源:拉勾教育大数据高薪训练营. 一致性 ...
- Python发送微信消息（文字、图片、文件）给指定好友和微信群（调用Win32 API模拟人的手动操作来发送消息）
本示例是调用Windows API模拟发送,用Python调用win32api这个库来调用Windows API模拟人的手动操作来发送消息. 在使用前,请将你微信的窗口设置为在最前面,这样就便于程序找 ...
- 【Kafka消息队列】生产者发送消息流程
如何描述一条消息? 如何描述一条消息,就是在问这条消息的数据结构是什么? public class ProducerRecord<K, V> {private final String t ...
- 10 kafka生产者发送消息的原理
1.发送原理: 在消息发送的过程中,涉及到了两个线程--main 线程和 Sender 线程.在 main 线程 中创建了一个双端队列 RecordAccumulator.main 线程将消息发送给 ...
- kafka控制台模拟消费_Kafka 详解
kafka简介 Kafka是最初由Linkedin公司开发,是一个分布式.支持分区的(partition).多副本的(replica),基于zookeeper协调的分布式消息系统,它的最大的特性就是可 ...
- 使用kafka消息队列中间件实现跨进程，跨服务器的高并发消息通讯
作者 | 陈屹 责编 | 欧阳姝黎 近来工作上接收到一项任务,实现c++后台服务器程序,要求它能承载千万级别的DAU读写请求.目前实现千万级高并发海量数据请求的服务器设计在"套路 ...
- 【kafka】控制台默认不能发送大数据 4096 4095 4129
本文为博主九师兄(QQ:541711153 欢迎来探讨技术)原创文章,未经允许博主不允许转载. 文章目录 1.概述 2.场景再现2 2.1 概述 M.参考 1.概述 因为某些原因,需要做一个测试,然后 ...
最新文章
- 地址引用PHP,浅谈PHP变量作用域以及地址引用问题
- 【嵌入式】Ubuntu20.04执行arm-linux-gc 没有那个文件或目录
- SQL中Truncate的用法
- jq select操作全集
- Python笔记-获取拉钩网南京关于python岗位数据
- 数据结构之内部排序算法总结笔记
- C++ 常见错误（03） —— cout输出图像路径
- 《数据结构和算法》之中缀表达式、后缀表达式转换
- 如何面对大容量的数据存储
- 【已解决】iOS程序出现警告：ARC Semantic Issue，Assigning retained object to unsafe property;object will be releas
- 腾讯短网址怎么在线生成
- 左右滑屏设置_android手势滑屏及左右滑屏
- 力扣算法——78_子集
- QT-局域网电脑远程桌面
- 盲打打字php,讯飞输入法盲打键盘闪亮登场 是时候展示你真正的技术了
- 写小说如何运用思维导图
- 怎么申请电子邮箱，电子邮件大全，商务人士都在用这个！
- 甘特图：编制项目计划的步骤
- Spring AOP【AOP的基本实现与动态代理JDK Proxy 和 CGLIB区别】
- IDEA如何打包war包