//暂停kafka的消费 暂停分区的分配consumer.unsubscribe();//此处不取消订阅暂停太久会出现订阅超时的错误consumer.pause(consumer.assignment());//重新消费分区,此处不重新分配会出错 this.open(null,null,null); ...
分类：
其他好文 时间：
2020-01-09 18:39:24
阅读次数：
1033
我在要完成这个需求的时候大概有两个思路。 第一种方法： 我们直接使用 Kafka 提供的 bin 工具，去把我们关心的 lag 值 show 出来然后通过代码处理一下报出来。例如： 我们可以起个远程的 cmd 脚本，定期去执行 kafka-consumer-groups.sh 工具然后通过 awk ...
分类：
编程语言 时间：
2020-01-08 19:08:27
阅读次数：
102
如果业务中，对于kafka发送消息异步消费的场景，在业务上需要实现在消费时实现顺序消费， 利用kafka在partition内消息有序的特点，消息消费时的有序性。 1、在发送消息时，通过指定partition hash 2、consumer 消费消息时，需要使用亲缘性线程池进行消费，才能实现消息的基 ...
分类：
其他好文 时间：
2020-01-04 14:13:35
阅读次数：
90
Description:
Field kafkaUtil in cn.arebirth.uesr.consumer.controller.TestUserController required a bean of type 'cn.arebirth.common.utils.KafkaUtil' ... ...
分类：
编程语言 时间：
2020-01-03 21:21:08
阅读次数：
66
1.原理图： 2.设计实现思路： 1.生产者（发送方）投递事务消息到Broker中，设置该消息为半消息 不可以被消费； 2.开始执行我们的本地事务，将本地事务执行的结果（回滚或者提交）发送给Broker； 3.Broker获取回滚或者提交，如果是回滚的情况则删除该消息、如果是提交的话，该消息就可以被 ...
分类：
其他好文 时间：
2020-01-03 10:39:00
阅读次数：
486
前提 最近创业公司的项目组基于业务需要，开发一套新的微服务，考虑到选用的组件必须是主流、社区活跃、生态完善以及方便迁移到云上等因素，引入了 全家桶。微服务开发里面，一个很重要的功能就是服务发现与注册，笔者花了点时间做了一个 、`SOFARpc Nacos`实现微服务发现注册与远程调用的示例。 依赖版 ...
分类：
其他好文 时间：
2020-01-02 18:51:18
阅读次数：
101
Windows 10 系统 - business editions 和 consumer editions 的区别 ...
实体类People，有个返回list的buildPeopleList方法，方便测试。 测试类GroupByTest，分别根据性别分组，统计各个性别人数，以及各个性别映射姓名。 ...
分类：
编程语言 时间：
2020-01-01 13:28:18
阅读次数：
252
@Component @RabbitListener(queues="my_fanout") public class Consumer { @RabbitHandler public void process(String msg){ System.out.println(msg); } } 但是 ...
分类：
编程语言 时间：
2019-12-30 19:20:34
阅读次数：
90
参考文章 https://blog.csdn.net/abcwanglinyong/article/details/81906027 该demo包含三个项目，分别是： 服务提供端项目：provider 服务消费端项目：consumer 共用服务接口项目：api 1、新建maven项目api 注意将其 ...
分类：
其他好文 时间：
2019-12-27 11:16:35
阅读次数：
74
