加载中
Kafka1.0.X_消费者API详解2

偏移量由消费者管理 kafka Consumer Api还提供了自己存储offset的功能,将offset和data做到原子性,可以让消费具有Exactly Once 的语义,比kafka默认的At-least Once更强大 消费者从指定分区...

06/25 07:21
190
Kafka1.0.X_消费者API详解1

kafka的消费者API提供从kafka服务端拉取消息的能力,kafka引入了消费者组的概念,不同消费者组之间互不影响,独自拥有一份数据,而同一个消费者组内的消费者则有如下规律: 分区数=消费者数:...

06/25 07:17
154
Kafka1.0.X_生产者API详解

Producer是Kafka三大组件中的一个,用于发送消息到kafka集群中 Producer提供了丰富的配置(见后面的配置项)用于控制它的行为 在编码之前先使用命令创建topic ./kafka-topics.sh --create --...

06/25 06:43
337
kafka可靠性分析

分区可靠性保证 Kafka维护一个AR(All Partition)列表,由ISR(与Leader数据同步的Replica)和OSR(与Leader数据不同步的Replica)组成。刚开始所有的副本都在ISR中,在kafka工作的过程中,...

06/19 13:04
22
开发人员MySQL调优-实战篇3-profile日志和锁

profile日志分析 通过使用explain命令查看执行计划,并对SQL调优后,如果还想对SQL执行过程更详细的了解,查找慢更底层的原因,可以使用profile分析。 打开日志记录 先查看profile配置 mysq...

06/14 09:41
12
开发人员MySQL调优-实战篇0-explain详解

本来应该先发这篇的,现在才发现漏掉了 项目中SQL优化流程 1.开发人员具备一定的SQL优化基本功 2.在开发阶段,每条写的SQL在测试环境看看他的执行计划 3.上线后让DBA收集查询比较慢的SQL 4.通...

06/13 15:43
40
开发人员MySQL调优-实战篇2-让SQL使用索引详解

建议先看看开发人员MySQL调优-实战篇0 让执行的SQL使用索引 虽然DBA给我们建了很多索引,但没有经验的开发人员往往只看表结构,不太关注索引和如何利用索引提高SQL执行速度,下面罗列一些经验...

06/12 23:28
21
开发人员MySQL调优-实战篇1-单_双表查询优化

建议先看看开发人员MySQL调优-实战篇0 单表案例分析 准备数据脚本 DROP TABLE IF EXISTS `tb_tmp_vote`; CREATE TEMPORARY TABLE `tb_tmp_vote` (   `id` int(10) unsigned NOT NULL AU...

06/11 22:23
33
开发人员MySQL调优-理论篇

修改字符集 查看字符集 show variables like 'character%' show variables like '%char%' 上面的两个命令都可以,我一般使用的下面的,会出来如下几个字符集设定的选项: character_set_clie...

06/11 22:20
13
spring-session实现分布式集群session的共享

前言    HttpSession是通过Servlet容器创建和管理的,像Tomcat/Jetty都是保存在内存中的。但是我们把应用搭建成分布式的集群,然后利用LVS或Nginx做负载均衡,那么来自同一用户的Http请求将...

06/09 08:59
5
kafka存储机制与读写流程

存储机制 kafka用topic对消息进行归类,每一个topic可以分为多个分区,分区中的消息不重复,每个分区又有很多个segment(段),segment是在磁盘上就是一对文件,包含index和log文件,两种文件...

06/08 17:08
6
kafka简介与安装使用

简介 kafka是一个分布式、高可用、速度快、基于磁盘的发布-订阅消息中间件。由LinkedIn公司使用Scala开发,后来又称为了Apache的顶级项目(Apache要逆天啊)。kafka使用topic对消息进行分类,...

06/07 19:03
112
证明scala属性及方法

scala属性及方法证明 方式1 代码: package com.jv.scala02 ​ abstract class Cat {  var name:String = "bosi" } 将编译后的代码使用Java Decompiler反编译后发现声明了一个私有变量,一...

06/07 10:20
10
JVM调优整理

Java内存模型 在进行调优之间,必须得对Java内存模型有一个较深的认识才行,否则会一脸懵逼。 图中的持久代(也叫永久代)在JDK1.8就没有了,取而代之的时候MetaSpace 关于JVM栈,分享一个博...

06/05 08:59
7
Redis 5.0-Stream 操作详解

简介 Stream是Redis 5.0引入的一种新数据类型,允许消费者等待生产者发送的新数据,还引入了消费者组概念,组之间数据是相同的(前提是设置的偏移量一样),组内的消费者不会拿到相同数据。这...

06/01 23:18
407
Redis:pub/sub实现消息发布/订阅

转载自http://www.runoob.com/redis/redis-pub-sub.html Redis 发布订阅 Redis 的 Pub/Sub 可以用来实现简单的订阅机制。一个或多个 client 向 Redis 订阅特定的频道,当某个 client 向这个频...

06/01 09:13
33
Flume安装与配置详解

Flume简介 一款分布式的海量应用日志采集、聚合、传输的框架,支持配置多种数据发送方与接收方,具有高可用、高可靠的特性。比如可以同时从文件目录、log4j、http、avro、kafka等渠道收集日志...

05/31 15:26
12
Phoenix安装与JDBC连接Phoenix

简介 原生的HBaseAPI使用起来真的比较麻烦,当然公司有架构师做一层封装,提供给开发人员使用应该还不错。如果么有架构师怎么办?Apache出的Phoenix就是干了架构师的工作,提供了jdbc接口对H...

05/30 17:43
53
HBase Java-API

环境准备 1.启动hadoop\zookeeper\hbase三大组件 2.在eclipse中新建一个普通的java工程 3.将hbase安装目录下lib目录中jar包复制到工程中,并添加到build-path中 基本操作 package com.jv.hba...

05/30 15:55
6
HBase安装与命令行操作

HBase简介 基于Hadoop的NoSql数据库,适合存储半结构化、非结构化的稀疏数据,提供增删改查能力。因为其底层是hdfs,所以具有存储海量数据,高容错,高可用等特点,可以达到关系型数据库(市...

05/28 23:37
12

没有更多内容

加载失败,请刷新页面

下一页

返回顶部
顶部