腾讯云开发者社区-腾讯云

开发者社区

文档建议反馈控制台

最新优惠活动

文章/答案/技术大牛

发布

爱明依

专栏作者

190

文章

250001

阅读量

25

订阅数

从源码分析如何优雅的使用 Kafka 生产者

缓存文件存储 kafka

在上文设计一个百万级的消息推送系统中提到消息流转采用的是 Kafka 作为中间件。

2022-04-01

4120

kafka :聊聊如何高效的消费数据。

编程算法 kafka

之前写过一篇《从源码分析如何优雅的使用 Kafka 生产者》，有生产者自然也就有消费者。

2022-04-01

8670

Kafka集群搭建与使用

bash bash 指令 zookeeper kafka 面向对象编程

Kafka是一种高吞吐量的分布式发布订阅消息系统，使用Scala编写。对于熟悉JMS（Java Message Service）规范的同学来说，消息系统已经不是什么新概念了(例如ActiveMQ，RabbitMQ等)。 Kafka拥有作为一个消息系统应该具备的功能，但是确有着独特的设计。可以这样来说，Kafka借鉴了JMS规范的思想，但是确并没有完全遵循JMS规范。 kafka是一个分布式的，分区的消息(官方称之为commit log)服务。它提供一个消息系统应该具备的功能，但是确有着独特的设计。首先，让我们来看一下基础的消息(Message)相关术语： Topic: Kafka按照Topic分类来维护消息 Producer：我们将发布(publish)消息到Topic的进程称之为生产者(producer) Consumer：我们将订阅(subscribe)Topic并且处理Topic中消息的进程称之为消费者(consumer) Broker： Kafka以集群的方式运行，集群中的每一台服务器称之为一个代理(broker)。因此，从一个较高的层面上来看，producers通过网络发送消息到Kafka集群，然后consumers来进行消费，如下图：

2020-12-07

7620

利用spring AOP、自定义注解、反射、kafka、mysql 实现日志收集存储分析

版权声明：本文为博主原创文章，未经博主允许不得转载。 https://blog.csdn.net/qq_32423845/article/details/88948668

2019-04-09

6500

`OutOfMemoryError` 问题相信很多朋友都遇到过，相对于常见的业务异常（数组越界、空指针等）来说这类问题是很难定位和解决的...

OutOfMemoryError 问题相信很多朋友都遇到过，相对于常见的业务异常（数组越界、空指针等）来说这类问题是很难定位和解决的。

2019-04-01

6520

没有更多了

社区活动

RAG七天入门训练营

鹅厂大牛手把手带你上手实战

Python精品学习库

代码在线跑，知识轻松学

博客搬家 | 分享价值百万资源包

自行/邀约他人一键搬运博客，速成社区影响力并领取好礼

技术创作特训营·精选知识专栏

往期视频·千货材料·成员作品最新动态