kafka消息重复消费解决方案

Kafka消费者以消费者组(Consumer Group)的形式消费一个topic,发布到topic中的每个记录将传递到每个订阅的消费者组中的一个消费者实例。Consumer Group 之间彼此独立,互不影响,它们能够订阅相同的一组主题而互不干涉。......

消息中间件Kafuka学习——初次配置使用

消息队列Kafuka学习

怎么避免服务内存溢出?

在高并发、高吞吐的场景下,很多简单的事情,会变得非常复杂,而很多程序并没有在设计时针对高并发高吞吐量的情况做好内存管理。自动内存管理机制的实现原理做内存管理,主要考虑申请内存和内存回收两部分。申请内存的步骤:计算要创建的对象需要占用多少内存在内存中找一块连续并且是空闲的内存空间,标记为已占用内存回收

【Linux】system V共享内存 | 消息队列 | 信号量

本篇博客主要讲解了什么是共享内存、共享内存的原理、用共享内存实现客户端和服务端的通信、什么是消息队列、消息量以及进程互斥等等。

【面试大全-MQ】-消息队列

解耦、异步、削峰解耦:一个系统或者说一个模块,调用了多个系统或者模块,互相之间很复杂,维护起来比较麻烦。但是这个接口不需要同步接口的,比如通知等,这个时候采用异步化进行解耦异步:某些操作,比如非事务操作,这个时候可以采用异步的方式削峰:减少高峰期对服务器的压力

RocketMQ源码(4)—Broker与NameServer的心跳服务源码

详细介绍了RocketMQ的Broker与NameServer的心跳服务源码。

【大话云原生】消息队列与快递柜之间妙不可言的关系(带视频)

提到消息队列可能一些朋友经常听别人说起一些名词,比如:服务程序解耦,处理流量削峰,通过异步处理提升用户体验,缓冲批处理提高处理性能。笔者擅于白话解说,所以我就不用专业的术语去解释专业的问题了。我一直觉得消息队列的功能和快递柜的功能非常相似,怎么个相似法呢?让我来详细给你说说。

CentOS 7.6环境安装kafka_2.13-3.0.0[单机版]

本节内容主要总结一下如何在CentOS 7.6上安装kafka 2.13-3.0.0注意:此单机版使用的是kafka自带的zookeeper1.组件版本组件 版本 CentOS 7.6 JDK 1.8.0_221 kafka 2.13-3.0.0 2.环境设置Init-env

RocketMQ源码解析-Broker部分之Broker启动过程

启动入口BrokerStartup

登录可以使用的更多功能哦! 登录
作者榜
...
资讯小助手

资讯同步

...
内容小助手

文章同步

...
Deephub

公众号:deephub-imba

...
奕凯

公众号:奕凯的技术栈