ack=0/1/-1的不同情况：0：producer不等待broker的ack，broker一接收到还没有写入磁盘就已经返回，当broker故障...
投稿
收录了11篇文章 · 1人关注
-
Kafka的ack机制
-
实时同步mysql数据到Elasticsearch（3.消费Kafka消息同步数据到ES）1、导入maven引用 2、配置文件如下： 3、初始化Jest客户端 4、实现Kafka批量消费 5、实现ES 通用业务逻辑层 6、实现消费逻辑...
-
Flink消费Kafka数据时指定offset的五种方式
下面是Flink读取Kafka数据的代码，其中就有五种读取offset的方式，并配置相应的介绍
-
kafka 修改副本数
本文完全参考官网：官网链接：https://kafka.apache.org/21/documentation.html#basic_ops_i...
-
Kafka auto.offset.reset值详解
昨天在写一个java消费kafka数据的实例，明明设置auto.offset.reset为earliest，但还是不从头开始消费，官网给出的含义...
-
Kafka拦截器（interceptor）功能
Producer拦截器(interceptor)是在Kafka 0.10版本被引入的，主要用于实现clients端的定制化控制逻辑。对于prod...
-
实时同步mysql数据到Elasticsearch（2.Binlog日志生产消息到Kafka）BinlogMiddleware服务主要负责监听Binlog日志，并将其发送到Kafka队列（及Kafka生产者）。 本示例模拟监听teemol...
-
Kafka 消费者远程读不到数据
kafka远程消费不到数据,但是也不报错远程主机用telnet命令去测试kafka以及zookeeper节点的9200端口以及2181端口都畅通...
-
Flink+Kafka 0.11端到端精确一次处理语义实现2017年12月Apache Flink社区发布了1.4版本。该版本正式引入了一个里程碑式的功能：两阶段提交Sink，即TwoPhaseComm...
-
用Kafka自带脚本实现Kafka消费情况实时监控
查看consumer组内消费的offset 在${KAFKA_HOME}/bin下./kafka-run-class.sh kafka.tool...
{var%20f='http://v.t.sina.com.cn/share/share.php?appkey=1881139527',u=z||d.location,p=['&url=',e(u),'&title=',e(t||d.title),'&source=',e(r),'&sourceUrl=',e(l),'&content=',c||'gb2312','&pic=',e(p||'')].join('');function%20a(){if(!window.open([f,p].join(''),'mb',['toolbar=0,status=0,resizable=1,width=440,height=430,left=',(s.width-440)/2,',top=',(s.height-430)/2].join('')))u.href=[f,p].join('');};if(/Firefox/.test(navigator.userAgent))setTimeout(a,0);else%20a();})(screen,document,encodeURIComponent,'','','https://upload.jianshu.io/collections/images/1884496/%E5%BE%AE%E4%BF%A1%E5%9B%BE%E7%89%87_20190710203045.jpg', '推荐专题《中间件》（ 分享自 @简书 ）','https://jianshuapi.com/c/832689bd62bc?utm_campaign=maleskine&utm_content=collection&utm_medium=reader_share&utm_source=weibo','页面编码gb2312|utf-8默认gb2312'));){kind=link}