Collection接口是List，Set，Queue接口的父接口，该接口里定义的方法既可用于操作Set集合，也可用于操作List和Queue集合。 1.使用Lambda表达式遍历集合 Java8为Iterable接口新增了一个forEach(Consumer action)默认方法，该方法所需参数 ...
分类：
其他好文 时间：
2020-05-23 13:24:06
阅读次数：
47
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
__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
一、Routing模式简介 RabbitMQ的路由模式，可以简单理解为，根据exchange绑定的key，将消息路由到不同的queue，模型图如下： 上图中几个关键点： Publisher:消息的生产者 Exchange:路由,类型为direct Queue:队列，存储消息的地方 Consumer: ...
分类：
其他好文 时间：
2020-05-15 13:31:28
阅读次数：
90
一：消息偏移量Offset 1. 什么是offset 1. message queue是无限长的数组，一条消息进来下标就会涨1，下标就是offset，消息在某个MessageQueue里的位置，通过offset的值可以定位到这条消息，或者指示Consumer从这条消息开始向后处理 2. messag ...
分类：
其他好文 时间：
2020-05-14 22:36:27
阅读次数：
112
public class LambdaTest2 { @Test public void test1(){ happyTime(500, new Consumer<Double>() { @Override public void accept(Double aDouble) { System.ou ...
分类：
其他好文 时间：
2020-05-14 19:33:54
阅读次数：
60
