kafka中文教程

项目说明通过传入开始和结束时间戳，重新消费kafka历史消息。```public static void main(String[] args) { String startTime = "2018-08-14 21:19:09"; // 开始时间 String endTi...

1. 前言对于使用Apache Kafka的Spring项目，我们在Spring核心提供了Kafka消息的集成。提供了公共的接入“模板”，作为消息发送的高级抽象层，还为消息的POJO提供支持。 3. 介绍本示例提供一个快速的入门例子，直接运行即可。 3.1. 快速游览（Quick Tour for...

说明此客户端是我很早之前封装的，支持`spring`，已经在生产运行8年有余，代码用于学习交流，也可用于生产。描述：- 生产者是同步提交，安全性最高- 消费者是手动提交offset，阻塞式消费，极端情况下，消息最多丢失一条。性能并非最优，但安全健壮性最高。...

zookeeper采用官方版本：3.5.7```docker run -d --cpus 0.5 -m 200M \--restart always \-u root \--name zookeeper \-p 2181:2181 \-p 2888:2888 \-p 3888:3888 \-v /e...

使用过`kafka`的小伙伴应该都知道`kafka`本身是没有管理界面的，所有操作都需要手动执行命令来完成。但有些命令又多又长，如果没有做笔记，别说是新手，就连老手也不一定能记得住，每次想要使用的时候都要上网搜索一下。有些崇尚geek精神的人或许觉得命令行才是真爱，但使用一款好用的可视化管理工具真的...

使用k8s安装[KafkaOffsetMonitor raft版监控](https://www.orchome.com/10551)。直接运行以下yaml即可：```apiVersion: apps/v1kind: Deploymentmetadata: name: kafka-offset-mo...