Kafka Kafka是最初由Linkedin公司开发，是一个分布式、支持分区的（partition）、多副本的（replica），基于zookeeper协调的分布式消息系统，它的最大的特性就是可以实时的处理大量数据以满足各种需求场景：比如基于hadoop的批处理系统、低延迟的实时系统、storm/ ...
分类：
其他好文 时间：
2020-05-23 18:03:51
阅读次数：
49
Collection接口是List，Set，Queue接口的父接口，该接口里定义的方法既可用于操作Set集合，也可用于操作List和Queue集合。 1.使用Lambda表达式遍历集合 Java8为Iterable接口新增了一个forEach(Consumer action)默认方法，该方法所需参数 ...
分类：
其他好文 时间：
2020-05-23 13:24:06
阅读次数：
47
relinquish vt. 1. VERB If you relinquish something such as power or control, you give it up. intergalactic adj. 1. ADJ Intergalatic space travel is tr ...
分类：
其他好文 时间：
2020-05-21 19:14:22
阅读次数：
63
Consumer 端有个位移的概念 它和消息在分区中的位移不是一回事儿 Consumer 的消费位移，它记录了 Consumer 要消费的下一条消息的位移。这可能和你以前了解的有些出入，不过切记是下一条消息的位移，而不是目前最新消费消息的位移 Consumer 需要向 Kafka 汇报自己的位移数据 ...
分类：
其他好文 时间：
2020-05-21 16:37:14
阅读次数：
68
1. 新建 cloud-consumer-feign-order80 2. pom.xml <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="htt ...
分类：
其他好文 时间：
2020-05-21 13:18:38
阅读次数：
47
消费者组（consumer group） 官方定义： 消费者使用一个消费者组（即group.id）来标记自己，topic的每条消息都只会被发送到每个订阅它的消费者组的一个消费者实例上。 基本概念 ~~~text 所有consumer实例都属于相同group 实现基于队列的模型。每条消息只会被一个co ...
分类：
其他好文 时间：
2020-05-20 17:16:33
阅读次数：
48
<script type="text/javascript"> $(function () { $('#btnShow').click(function (event) { //取消事件冒泡 event.stopPropagation(); //设置弹出层的位置 var offset = $(eve ...
分类：
Web程序 时间：
2020-05-19 14:53:46
阅读次数：
89
__consumer_offsets 在 Kafka 源码中有个更为正式的名字，叫位移主题，即 Offsets Topic。需要注意的是，它有两个下划线哦 将 Consumer 的位移数据作为一条条普通的 Kafka 消息，提交到 __consumer_offsets 中 可以这么说，__consu ...
分类：
其他好文 时间：
2020-05-19 12:58:45
阅读次数：
67
本例子基于 spring boot + spring cloud alibaba + spring cloud, nacos作为服务注册中心和配置中心。 简介 Nacos 是Spring Cloud Alibaba 的一个组件。致力于发现、配置和管理微服务。 Nacos名字：前四个字母分别为 Nam ...
分类：
其他好文 时间：
2020-05-18 18:14:22
阅读次数：
1990
Consumer Group 是 Kafka 提供的可扩展且具有容错性的消费者机制 既然是一个组，那么组内必然可以有多个消费者或消费者实例（Consumer Instance），它们共享一个公共的 ID，这个 ID 被称为 Group ID 组内的所有消费者协调在一起来消费订阅主题（Subscrib ...
分类：
其他好文 时间：
2020-05-18 12:48:42
阅读次数：
76
