首页
学习
活动
专区
工具
TVP
发布

cwl_Java

专栏成员
2423
文章
2232643
阅读量
65
订阅数
快速学习-Druid数据摄入
一些简单的聚合函数: count 、longSum、longMin、longMax、doubleSum、doubleMin、doubleMax
cwl_java
2022-11-30
7520
快速学习-Mycat事务支持
Mycat 目前没有出来跨分片的事务强一致性支持,目前单库内部可以保证事务的完整性,如果跨库事务,在执行的时候任何分片出错,可以保证所有分片回滚,但是一旦应用发起 commit 指令,无法保证所有分片都成功考虑到某个分片挂的可能性不大所以称为弱 xa。
cwl_java
2021-12-30
5390
快速学习-Mycat事务支持
Mycat 目前没有出来跨分片的事务强一致性支持,目前单库内部可以保证事务的完整性,如果跨库事务,在执行的时候任何分片出错,可以保证所有分片回滚,但是一旦应用发起 commit 指令,无法保证所有分片都成功考虑到某个分片挂的可能性不大所以称为弱 xa。
cwl_java
2021-08-30
3780
快速学习-RocketMQ-“Request-Reply”特性
随着服务规模的扩大,单机服务无法满足性能和容量的要求,此时需要将服务拆分为更小粒度的服务或者部署多个服务实例构成集群来提供服务。在分布式场景下,RPC是最常用的联机调用的方式。
cwl_java
2020-09-21
2K0
快速学习-RocketMQ样例
异步消息通常用在对响应时间敏感的业务场景,即发送端不能容忍长时间地等待Broker的响应。
cwl_java
2020-09-21
1.5K0
快速学习-RocketMQ特性(features)
消息的发布是指某个生产者向某个topic发送消息;消息的订阅是指某个消费者关注了某个topic中带有某些tag的消息,进而从该topic消费数据。
cwl_java
2020-09-21
6930
快速学习-RocketMQ DefaultMQProducer
public class DefaultMQProducer extends ClientConfig implements MQProducer
cwl_java
2020-09-18
3.1K0
经典面试题-2020年大厂面试题锦集
高可靠分布式存储模型 在 Kafka 中保证高可靠模型依靠的是副本机制,有了副本机制之后,就算机器宕机也不会发生数据丢失
cwl_java
2020-07-21
2700
经典面试题-Kafka
第 7 章 Kafka 面试题 7.1 面试问题 Kafka 中的 ISR(InSyncRepli)、OSR(OutSyncRepli)、AR(AllRepli)代表什么? Kafka 中的 HW、LEO 等分别代表什么? Kafka 中是怎么体现消息顺序性的? Kafka 中的分区器、序列化器、拦截器是否了解?它们之间的处理顺序是什么? Kafka 生产者客户端的整体结构是什么样子的?使用了几个线程来处理?分别是什么? “消费组中的消费者个数如果超过 topic 的分区,那么就会有消费者消费不到数据”这句
cwl_java
2020-02-24
6160
快速学习-Kafka API
Kafka 的 Producer 发送消息采用的是异步发送的方式。在消息发送的过程中,涉及到了两个线程——main 线程和 Sender 线程,以及一个线程共享变量——RecordAccumulator。main 线程将消息发送给 RecordAccumulator,Sender 线程不断从 RecordAccumulator 中拉取消息发送到 Kafka broker。
cwl_java
2020-02-24
7150
快速学习-Kafka概述
Kafka 是一个分布式的基于发布/订阅模式的消息队列(Message Queue),主要应用于大数据实时处理领域。 1.2 消息队列
cwl_java
2020-02-24
2570
快速学习-Kafka入门
注意:分发之后记得配置其他机器的环境变量 7)分别在 hadoop103 和 hadoop104 上修改配置文件/opt/module/kafka/config/server.properties中的 broker.id=1、broker.id=2 注:broker.id 不得重复
cwl_java
2020-02-24
3990
快速学习-Kafka架构深入
Kafka 中消息是以 topic 进行分类的,生产者生产消息,消费者消费消息,都是面向 topic的。
cwl_java
2020-02-24
3800
快速学习-Kafka Streams
Kafka Streams。Apache Kafka开源项目的一个组成部分。是一个功能强大,易于使用的库。用于在Kafka上构建高可分布式、拓展性,容错的应用程序。
cwl_java
2020-02-20
8250
快速学习-Flume 对接 Kafka
2) 启动 kafkaIDEA 消费者 3) 进入 flume 根目录下,启动 flume
cwl_java
2020-02-20
6310
快速学习-Kafka 监控
第 5 章 Kafka 监控 5.1 Kafka Eagle 修改 kafka 启动命令 修改 kafka-server-start.sh 命令中 if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G" fi 为 if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then export KAFKA_HEAP_OPTS="-server -Xms2G -Xmx2G -XX:PermSiz
cwl_java
2020-02-20
6950
快速学习-RabbitMQ基本介绍
MQ全称为Message Queue,即消息队列, RabbitMQ是由erlang语言开发,基于AMQP(Advanced Message Queue 高级消息队列协议)协议实现的消息队列,它是一种应用程序之间的通信方法,消息队列在分布式系统开 发中应用非常广泛。RabbitMQ官方地址:http://www.rabbitmq.com/
cwl_java
2020-01-14
4160
大数据-Flume介绍
1. Flume 介绍 1.1. 概述 Flume是一个分布式、可靠、和高可用的海量日志采集、聚合和传输的系统。 Flume可以采集文件,socket数据包、文件、文件夹、kafka等各种形式源数据,又可以将采集到 的数据(下沉sink)输出到HDFS、hbase、hive、kafka等众多外部存储系统中 一般的采集需求,通过对flume的简单配置即可实现 Flume针对特殊场景也具备良好的自定义扩展能力, 因此,flume可以适用于大部分的日常数据采集场景 1.2. 运行机制 Flume分布式系统中最核
cwl_java
2019-12-26
3520
没有更多了
社区活动
【纪录片】中国数据库前世今生
穿越半个世纪,探寻中国数据库50年的发展历程
Python精品学习库
代码在线跑,知识轻松学
博客搬家 | 分享价值百万资源包
自行/邀约他人一键搬运博客,速成社区影响力并领取好礼
技术创作特训营·精选知识专栏
往期视频·千货材料·成员作品 最新动态
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档