注册会员 | 设为首页 | 加入收藏夹
您好，欢迎光临本网站！[请登录] ！[注册会员]！  

搜索资源列表

  1. kafka & mafka client开发与实践

  2. 内容介绍： Kafka是一个高吞吐量分布式消息系统。linkedin开源的kafka。 Kafka就跟这个名字一样，设计非常独特。 首先，kafka的开发者们认为不需要在内存里缓存什么数据，操作系统的文件缓存已经足够完善和强大，只要你不搞随机写，顺序读写的性能是非常高效的。kafka的数据只会顺序append，数据的删除策略是累积到一定程度或者超过一定时间再删除。Kafka另一个独特的地方是将消费者信息保存在客户端而不是MQ服务器，这样服务器就不用记录消息的投递过程，每个客户端都自己知道自己下

  3. 所属分类：讲义

    • 发布日期：2016-12-19
    • 文件大小：1048576
    • 提供者：wohenkeai

  1. 大数据 分布式 读写 kafka

  2. 之前在实验室，采用maven方式编写的一个验证框架模型，读写分布式kafka数据，数据源可以有多种，实体文档或者RDMS. 对大数据分布式开发有兴趣朋友，可以看看。

  3. 所属分类：kafka

    • 发布日期：2017-09-24
    • 文件大小：23552
    • 提供者：jameszhang28

  1. kafka配置安装详解

  2. kafka配置安装详解及启动测试指南，基本入门教程，读写数据样例

  3. 所属分类：kafka

    • 发布日期：2018-04-11
    • 文件大小：13312
    • 提供者：t719999727

  1. kafka学习文档

  2. apache kafka 在数据处理中特删是日志和消息的处理上会有徆多出色的表现.首先弼然推荐的是 kafka 的宏 网 http://kafka.apache.org/。在宏网最值得参考的文章就是 kafka design: http://kafka.apache.org/design.html，要特删重规返篇文章，里面有好多理念都特删好，推荐多读几遍。 在 OSC 的翻译频道有 kafka design 全中文的翻译，翻得挺好的，推荐一下: http://www.oschina.net/t

  3. 所属分类：kafka

    • 发布日期：2018-05-30
    • 文件大小：1048576
    • 提供者：qq_24895615

  1. Kafka读数工具

  2. 一款简单易操作的kafka读取数据的工具，使用方法内附有详细说明。lib中加入系列化的jar包，启动kafka-tool.bat,选择并填写好序列化方式以及kafka的信息即可以使用。

  3. 所属分类：kafka

    • 发布日期：2018-06-22
    • 文件大小：19922944
    • 提供者：turnhopesliu

  1. kafka客户端

  2. 1/kafka是一个分布式的消息缓存系统 2/kafka集群中的服务器都叫做broker 3/kafka有两类客户端，一类叫producer（消息生产者），一类叫做consumer（消息消费者），客户端和broker服务器之间采用tcp协议连接 4/kafka中不同业务系统的消息可以通过topic进行区分，而且每一个消息topic都会被分区，以分担消息读写的负载 5/每一个分区都可以有多个副本，以防止数据的丢失 6/某一个分区中的数据如果需要更新，都必须通过该分区所有副本中的leader来更新

  3. 所属分类：群集服务

    • 发布日期：2018-09-04
    • 文件大小：55574528
    • 提供者：weixin_43128574

  1. kafka消息队列样例

  2. kafka消息队列消费者生产者读写样例。Kafka是一种高吞吐量的分布式发布订阅消息系统，它可以处理消费者规模的网站中的所有动作流数据。

  3. 所属分类：Java

    • 发布日期：2018-09-07
    • 文件大小：8192
    • 提供者：yanucie1

  1. 2017最新大数据架构师精英课程

  2. 本资源为大数据基础到中高级教学资源，适合稍微有点大数据或者java基础的人群学习，资源过大，上传乃是下载链接，不多说，上目录： 1_java基础2 l3 a2 a$ t7 J2 b+ `- p 2_java引入ide-eclipse 3_java基础知识-循环-类型转换 4_循环-函数-数组-重载 5_多为数组-冒泡-折半-选择排序 6_oop-封装-继承-static-final-private 7_多态-接口-异常体系 8_适配器/ k% N! Y7 j/ |- c) O5 M' V6 S

  3. 所属分类：Java

  1. 2019年SpringBoot面试专题及答案.pdf

  2. 2019年最新整理SpringBoot面试专题及答案,希望的大家互相交流!server port =8090 问题八 什么是YAML? YAML是一种人类可读的数据序列化语言。它通常用于配置文件。 与属性文件相比,如果我们想要在配置文件中添加复杂的属性,YAML文件就吏加结杓 化,而且更少混淆。可以看出YAML具有分层配置数据。 问题九 如何实现 Spring boot应用程序的安全性? 为了实现 Spring boot的安全性,我们使用 spring-boot-starter-security

  3. 所属分类：Java

    • 发布日期：2019-07-06
    • 文件大小：439296
    • 提供者：xiaofeivip_top

  1. SpringBoot面试专题及答案.pdf

  2. 什么是 Spring Boot？Spring Boot 有哪些优点？什么是 JavaConfig？如何重新加载 Spring Boot 上的更改，而无需重新启动服务器？server port =8090 问题八 什么是YAML? YAML是一种人类可读的数据序列化语言。它通常用于配置文件 与属性文件相比,如果我们想要在配置文件中添加复杂的属性,YAML文件就吏加结构 化,而且更少混淆。可以看出YAML具有分层配置数据。 问题儿 如何实现 Spring boot应用程序的安全性? 为了实现 Spr

  3. 所属分类：Java

    • 发布日期：2019-07-02
    • 文件大小：353280
    • 提供者：luck332

  1. Hadoop安装手册

  2. Hadoop在大数据技术体系中的地位至关重要，Hadoop是大数据技术的基础，对Hadoop基础知识的掌握的扎实程度，会决定在大数据技术道路上走多远。525将 HBase安装文件复制到 HadoopSlave节点… 83 53启动并验证 HBase 83 第6章安装部署 Mahout 86 6.1解压并安装 Mahout… 87 6.2启动并验证 Mahout 88 第7章安装部署 Snoop… 0 7.1解压并安装 Scoop… 90 7.2配置 Scoop 91 7.2.1配置 MySQL连

  3. 所属分类：Java

    • 发布日期：2019-03-02
    • 文件大小：6291456
    • 提供者：qq_35513792

  1. Flink入门：读取Kafka实时数据流，实现WordCount

  2. 本文主要介绍Flink接收一个Kafka文本数据流，进行WordCount词频统计，然后输出到标准输出上。通过本文你可以了解如何编写和运行Flink程序。 代码拆解 首先要设置Flink的执行环境： // 创建Flink执行环境 StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); 设置Kafka相关参数，连接对应的服务器和端口号，读取名为Shakespeare的Topic

  3. 所属分类：其它

    • 发布日期：2021-01-07
    • 文件大小：447488
    • 提供者：weixin_38659527

  1. Kafka 笔记

  2. Kafka 文章目录Kafka架构名次解释Producer（生产者）命令使用脚本常用参数举例分区策略发送返回值幂等性Consumer（消费者）命令使用脚本常用参数举例分配策略Topic（主题）命令使用脚本常用参数举例Kafka高读写 一个分区内的数据才能保证幂等性和有序性 架构 名次解释 Broker：Kafka服务器 Producer：生产者，生产消息 Consumer：消费者，消费数据 Consumer Group：消费者组，某一个分区只能被同一个消费者组内的一个消费者消费 Topic：消

  3. 所属分类：其它

    • 发布日期：2021-01-07
    • 文件大小：311296
    • 提供者：weixin_38748875

  1. kafka:kafka原始码分析-源码

  2. kafka原始码解析 kafka关键概念 主题用于划分消息的逻辑概念，一个主题可以分布在多个代理上。 分区是Kafka中横向扩展和一切并行化的基础，每个主题都至少被切分为1个分区。 偏移消息在Partition中的编号，编号顺序不跨Partition（在Partition内有序）。 Consumer用于从Broker中取/消费Message。 Producer用于往Broker中发送/生产消息。 复制Kafka支持以Partition为单位对消息进行冗余备份，每个Partition都可

  3. 所属分类：其它

    • 发布日期：2021-03-23
    • 文件大小：4194304
    • 提供者：weixin_42137022

  1. practice:知识梳理：数据结构和算法，leetcode解题记录，手写生产者-消费者模型，SpringAOP，Springboot自定义注释解，异常异常处理，整合Mybatis，整合Redis，mybatis逆向工程，死锁，同步锁，读-

  2. 欢迎大家来到Higmin GitHub项目！ 创建此工程是为了巩固基础知识当然能对社区做点贡献也是我小小的心愿〜 本工程包含了SpringAOP，死锁，JUC同步锁，读-写同步锁，线程本地使用，JUC线程池和Spring提供的线程池，jdk 1.8中的日期时间API，数据结构中图的实现及操作和广度优先遍历/深度优先遍历（其他待完善），生成XML文件工具类，防止XSS攻击解决方案，mybatis逆向工程，接口并发测试，BIO，NIO，AIO，Netty的服务，客户端...以及在不断更新中，有不足之

  3. 所属分类：其它

    • 发布日期：2021-03-18
    • 文件大小：407552
    • 提供者：weixin_42137028

  1. datacollector:StreamSets Data Collector-连续的大数据和云平台获取基础架构-源码

  2. 什么是StreamSets数据收集器？ StreamSets Data Collector是企业级的，开源的，连续的大数据摄取基础架构。 它具有先进且易于使用的用户界面，使数据科学家，开发人员和数据基础架构团队可以轻松地在创建复杂摄取场景所需的短时间内创建数据管道。 开箱即用的StreamSets Data Collector可以读写大量端点，包括S3，JDBC，Hadoop，Kafka，Cassandra等。 除了大量的预建阶段之外，您还可以使用Python，Javascr ipt和Java

  3. 所属分类：其它

    • 发布日期：2021-03-17
    • 文件大小：88080384
    • 提供者：weixin_42135773

  1. 公共安全领域Kafka应用实践

  2. 本案例作为大数据框架在公共安全领域应用实践的开篇之作，将从最基础的数据架构体系优化讲起。在接下来的章节里将详细描述Kafka的基本原理、Kafka增强组件以及基于Kafka的Lambda架构的具体应用场景以及相应的研发成果。Lambda架构由Storm的作者NathanMarz提出。旨在设计出一个能满足。实时大数据系统关键特性的架构，具有高容错、低延时和可扩展等特。Lambda架构整合离线计算和实时计算，融合不可变（Immutability，读写分离和隔离一系列构原则，可集成Hadoop，Kaf

  3. 所属分类：其它

    • 发布日期：2021-02-24
    • 文件大小：989184
    • 提供者：weixin_38560768

  1. kafka-connect-spooldir：Kafka Connect连接器，用于将CSV文件读入Kafka-源码

  2. 介绍 通过安装 该Kafka Connect连接器提供了监视目录的文件和在将新文件写入输入目录时读取数据的功能。 输入文件中的每个记录将根据用户提供的模式进行转换。 CSVRecordProcessor支持读取CSV或TSV文件。 它可以将CSV即时转换为强类型的Kafka Connect数据类型。 当前，它支持Kafka Connect支持的所有架构类型和逻辑类型。 如果将其与Confluent的Avro转换器和Schema Registry结合使用，您将能够实时处理CSV，Json或TSV

  3. 所属分类：其它

    • 发布日期：2021-02-03
    • 文件大小：217088
    • 提供者：weixin_42151036

  1. seconds-kill：基于Springboot + Redis + Kafka的秒杀系统，乐观锁+缓存+限流+异步，TPS从500优化到3000-源码

  2. 如何设计一个秒杀系统 系统的特点 高效：秒杀涉及大量的并发读和并发写，因此支持高并发访问这点非常关键 一致性：秒杀商品减库存的实现方式同样关键，有限数量的商品在同一时刻被很多倍的请求同时来减库存，在大并发更新的过程中都要保证数据的准确性。 高可用：秒杀时会在一瞬间涌入大量的流量，为了避免系统停机机，保证高可用，需要做好流量限制 优化思路 初步优化：将请求阻止拦截在系统上游 假设现在库存为10，有1000个购买请求，最终只有10个可以成功，99％的请求都是无效请求 削峰：秒杀请求在时间上高度集中于

  3. 所属分类：其它

    • 发布日期：2021-02-02
    • 文件大小：103424
    • 提供者：weixin_42140846

  1. 公共安全领域Kafka应用实践

  2. 本案例作为大数据框架在公共安全领域应用实践的开篇之作，将从最基础的数据架构体系优化讲起。在接下来的章节里将详细描述Kafka的基本原理、Kafka增强组件以及基于Kafka的Lambda架构的具体应用场景以及相应的研发成果。Lambda架构由Storm的作者NathanMarz提出。旨在设计出一个能满足。实时大数据系统关键特性的架构，具有高容错、低延时和可扩展等特。Lambda架构整合离线计算和实时计算，融合不可变（Immutability，读写分离和隔离 一系列构原则，可集成Hadoop

  3. 所属分类：其它

    • 发布日期：2021-01-27
    • 文件大小：989184
    • 提供者：weixin_38522636
« 12 »