当集群中有新成员加入，或者某些主题增加了分区之后，消费者是怎么进行重新分配消费的？这里就涉及到重平衡（Rebalance）的概念，下面我就给大家讲解一下什么是 Kafka 重平衡机制，我尽量做到图文并茂通俗易懂。 重平衡的作用 重平衡跟消费组紧密相关，它保证了消费组成员分配分区可以做到公平分配，也是 ...
分类：
其他好文 时间：
2020-07-18 00:48:57
阅读次数：
97
AllowAnonymousAttribute Class // System.Web.Http.AuthorizeAttribute // Token: 0x0600010A RID: 266 RVA: 0x000048D5 File Offset: 0x00002AD5 private stat ...
分类：
其他好文 时间：
2020-07-17 22:19:11
阅读次数：
78
一、 创建一张表用于存放抓取到的Running SQL USE [dba_monitor] GO CREATE TABLE [running_sql_monitor]( [id] [int] IDENTITY(1,1) NOT NULL PRIMARY KEY, [Insert_Time] [dat ...
分类：
数据库 时间：
2020-07-17 19:53:10
阅读次数：
107
打开OEM-sql监视页面，出现如下报错：java.sql.SQLException:ORA-31011:XML语法分析失败ORA-19202:XML处理LPX-00225:结束元素标记"sql"与起始元素标记"action"不匹配Erroratline46376时出错ORA-06512:在"SYS.DBMS_SQLTUNE",line1
分类：
数据库 时间：
2020-07-17 16:27:27
阅读次数：
106
--语句新建一个定时任务 declare job number;BEGIN DBMS_JOB.SUBMIT( JOB => job, /*自动生成JOB_ID*/ WHAT => 'p_monitor_tablespace;', /*需要执行的存储过程名称或SQL语句*/ NEXT_DATE => ...
分类：
数据库 时间：
2020-07-16 21:24:07
阅读次数：
107
AbstractApplicationContext @Override public void refresh() throws BeansException, IllegalStateException { synchronized (this.startupShutdownMonitor) { ...
分类：
编程语言 时间：
2020-07-16 11:43:49
阅读次数：
72
Kafka-可靠性保证-保证了哪些可靠性 ACID是关系型数据库普遍支持的标准可靠性保证。 ACID：原子性(atomicity)、一致性(consistency)、隔离性(isolation)、持久性(durability) 如果数据库遵循ACID规范，那么该数据库就支持与事务相关的行为。 kaf ...
分类：
其他好文 时间：
2020-07-16 00:19:13
阅读次数：
71
这篇文章主要用来介绍Kafka & Zookeeper相关基础知识。 1. Kafka是由Linkedin开发，是一个分布式、支持分区的（partition）、多副本的（replica），基于zookeeper协调的分布式消息系统，它的最大的特性就是可以实时的处理大量数据以满足各种需求场景，之后于2 ...
分类：
编程语言 时间：
2020-07-15 23:49:56
阅读次数：
93
1.flume连接mysql驱动包准备 进入链接下载源码https://github.com/keedio/flume-ng-sql-source现在最新是1.5.3解压， 进入到目录中编译 直接编译可能报错，跳过test mvn package -DskipTests 2.flume与kafka, ...
分类：
数据库 时间：
2020-07-15 23:28:07
阅读次数：
166
我们知道Logstash的架构如下： 它的整个pipleline分为三个部分： input插件：提取数据。 这可以来自日志文件，TCP或UDP侦听器，若干协议特定插件（如syslog或IRC）之一，甚至是排队系统（如Redis，AQMP或Kafka）。 此阶段使用围绕事件来源的元数据标记传入事件。 ...
分类：
其他好文 时间：
2020-07-15 23:00:31
阅读次数：
84
