Kafka 是现在大数据中流行的消息中间件，其中 kafka 中由 topic 组成，而 topic 下又可以由多个 partition 构成。有时候我们在消费 kafka 中的数据想要保证消费 kafka 中的所有的分区下数据是全局有序的，这种情况下就需要将 topic 下的 partition ...
分类：
其他好文 时间：
2020-05-25 09:38:02
阅读次数：
231
Kafka快速入门（二）——Kafka架构一、Kafka架构简介1、Kafka架构简介2、RecordRecord即Kafka消息，是Kafka处理的主要对象。3、TopicTopic是承载Kafka消息数据的逻辑容器，用于区分具体的业务，但在物理上，不同Topic的消息分开存储，逻辑上一个Topic的消息虽然保存在一个或多个Broker上，但用户只需指定消息的Topic即可生产或消费数据而不必关
分类：
其他好文 时间：
2020-05-24 10:09:12
阅读次数：
47
同样是逻辑上的概念，是Kafka实现单播和广播两种消息模型的手段。同一个topic的数据，会广播给不同的group；同一个group中的worker，只有一个worker能拿到这个数据。换句话说，对于同一个topic，每个group都可以拿到同样的所有数据，但是数据进入group后只能被其中的一个w ...
分类：
其他好文 时间：
2020-05-24 10:06:48
阅读次数：
77
这在实际应用中是非常现实的需求，学好这个非常重要。但在ROS官网以及相关书籍、博客上找了一下，介绍多Topic收发的相对较少，大部分还是停留在一个节点只做一件事(收或发)的水平，所以本篇博客希望可以引导深入学习Topic
分类：
其他好文 时间：
2020-05-21 19:41:58
阅读次数：
164
消费者组（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
五类Kafka客户端作用和区别在上文中介绍了如何搭建一个Kafka服务，那么在开发中我们要如何去访问、集成Kafka呢？这就需要使用到本文将要介绍的Kafka客户端API。下图是官方文档中的一个图，形象表示了能与Kafka集成的客户端类型：这些客户端通过API与Kafka进行集成，Kafka的五类客户端API类型如下：AdminClientAPI：允许管理和检测Topic、broker以及其他Ka
写在前面 实际上我从未想过我会接触到H5小游戏开发，那是在2015年末，当时我还刚开始学习iOS不久，用Swift在写一个类似于Snapchat的应用。由于公司项目转型，需要创造一个小游戏平台，需要使用一个比较成熟的前端游戏框架来快速开发小游戏。都说创业公司有无限的实践机会，于是，我就接触到了Pha ...
分类：
Web程序 时间：
2020-05-15 20:38:09
阅读次数：
106
session setMaxInactiveInterval() for each page? |?Oracle Community https://community.oracle.com/thread/1446482 Spring Security: set session max inacti ...
分类：
编程语言 时间：
2020-05-15 11:39:13
阅读次数：
98
转自：https://hacpai.com/article/1558144768869 oracle mysql 注：help_topic 为 mysql 存储内置函数的表 ...
分类：
数据库 时间：
2020-05-13 17:24:46
阅读次数：
83
