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

搜索资源列表

  1. kafka生产者连接池

  2. 封装抽取了一个kafka生产者的连接池，能很好的用池的方式对kafka生产者连接点进行有效的管理

  3. 所属分类：Java

  1. spring-kafka-demo

  2. spring封装的kafka生产消费 ，分别针对生产者和消费者做了不同的代码测试样例

  3. 所属分类：Java

    • 发布日期：2015-09-16
    • 文件大小：169kb
    • 提供者：yeshucheng

  1. librdkafka-master

  2. kafkaC和C++第三方接口，里面有C的接口并且封装了C++的接口，还有两个供大家学习的例子

  3. 所属分类：群集服务

    • 发布日期：2015-12-23
    • 文件大小：18kb
    • 提供者：kenochai

  1. cppkafka源代码

  2. kafka封装 C++11 使用 学习C++11与kafka封装不错的资料源代码

  3. 所属分类：kafka

    • 发布日期：2017-10-26
    • 文件大小：120kb
    • 提供者：haobide

  1. kafka基础代码

  2. kafka-基本代码封装，kafka-基本代码封装kafka-基本代码封装

  3. 所属分类：Java

    • 发布日期：2017-11-09
    • 文件大小：9kb
    • 提供者：liruizi

  1. ZooKeeper-分布式过程协同技术详解

  2. 本书分三部分，共章。部分（第～章）阐述这类系统的设计目的和动机，并介绍分布式系统的一些必要背景知识。第章介绍可以做什么，以及其设计如何支撑这些任务。第章介绍基本概念和基本组成模块，并通过命令行工具的具体操作介绍了可以做什么。第二部分（第～章）阐述开发人员所需要掌握的库调用方法和编程技巧。第章介绍语言的第章解释如何跟踪和处理中的状态变更情况。第章介绍如何在系统或网络故障时恢复应用。第章介绍需要注意来避免故障的一些繁杂却很重要的场景。第章介绍语言版的接口，也可以作为非语言实现的的基础，对非语言的开

  3. 所属分类：kafka

    • 发布日期：2018-04-04
    • 文件大小：3mb
    • 提供者：phearcy

  1. kafka封装源码

  2. kafka java生产-消费调用代码 kafka java调用代码 kafka java调用代码

  3. 所属分类：Java

    • 发布日期：2018-05-16
    • 文件大小：44kb
    • 提供者：jgy510510510

  1. Spring Cloud官方教程

  2. Spring Cloud的子项目，大致可分成两类，一类是对现有成熟框架"Spring Boot化"的封装和抽象，也是数量最多的项目;第二类是开发了一部分分布式系统的基础设施的实现，如Spring Cloud Stream扮演的就是kafka, ActiveMQ这样的角色。对于我们想快速实践微服务的开发者来说，第一类子项目就已经足够使用，如: Spring Cloud Netflix是对Netflix开发的一套分布式服务框架的封装，包括服务的发现和注册，负载均衡、断路器、REST客户端、请求路由

  3. 所属分类：Java

    • 发布日期：2018-06-12
    • 文件大小：2mb
    • 提供者：r115277

  1. Cloud分布式微服务

  2. SpringCloud Config 将配置信息中央化保存, 配置SpringCloud Bus可以实现动态修改配置文件。 SpringCloud Bus 分布式消息队列，是对Kafka, MQ的封装。 SpringCloud Security 对Spring Security的封装，并能配合Netflix使用。

  3. 所属分类：Java

    • 发布日期：2018-08-02
    • 文件大小：131kb
    • 提供者：qq_40225448

  1. mykafka_C++

  2. Linux qtcreator下kafka之librdkafka库的C++封装，实现生产和消费

  3. 所属分类：C++

    • 发布日期：2018-02-01
    • 文件大小：5kb
    • 提供者：libaineu2004

  1. Linux qtcreator下kafka之librdkafka库的C++语言封装，实现生产和消费，配套源码

  2. Linux qtcreator下kafka之librdkafka库的C++语言封装，实现生产和消费

  3. 所属分类：C++

    • 发布日期：2018-02-02
    • 文件大小：4kb
    • 提供者：libaineu2004

  1. 【白雪红叶】JAVA学习技术栈梳理思维导图.xmind

  2. 关于java程序员发展需要学习的路线整理集合 技术 应用技术 计算机基础知识 cpu mem disk net 线程，进程 第三方库 poi Jsoup zxing Gson 数据结构 树 栈 链表 队列 图 操作系统 linux 代码控制 自动化代码检查 sonar 代码规范 *Java开发规范手册 UMPAY——编码规范 日志规范 异常规范 网络 协议 TCP/IP HTTP hession file HTTPS 负载均衡 容器 JBOSS tomcat resin jetty 容灾

  3. 所属分类：Java

    • 发布日期：2018-04-25
    • 文件大小：609kb
    • 提供者：zhuguang_2016

  1. kafka封装 订阅和发布类

  2. kafka封装类，简单封装了kafka的订阅和发布，方便订阅数据

  3. 所属分类：C++

    • 发布日期：2018-09-15
    • 文件大小：4kb
    • 提供者：lijianbo1984

  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

    • 发布日期：2018-11-01
    • 文件大小：274byte
    • 提供者：weixin_38652136

  1. php-kafka-consumer.zip

  2. php-kafka-consumer 主要是对 php_rdkafka 的 consumer 的 API 进行一层封装，增加了原程序中所没有的与 zookeeper 交互的功能。在此基础上实现了 rebalance 功能以及 group 功能。 经过简单的压力测试，单个进程的消费能力能达到每秒钟7.8W条，压测详细内容见压力测试。依赖php_zookeeperphp_rdkafka （建议使用1.0.0版本）librdkafka（建议使用0.9.1版本）使用errstr(); } $consu

  3. 所属分类：其它

    • 发布日期：2019-07-19
    • 文件大小：19kb
    • 提供者：weixin_39840387

  1. phpkafkaconsumer是一个kafkaconsumer库支持group和rebalance

  2. php-kafka-consumer 主要是对 php_rdkafka 的 consumer 的 API 进行一层封装，增加了原程序中所没有的与 zookeeper 交互的功能。

  3. 所属分类：其它

    • 发布日期：2019-08-08
    • 文件大小：19kb
    • 提供者：weixin_39841856

  1. python3连接kafka模块pykafka生产者简单封装代码

  2. 今天小编就为大家分享一篇python3连接kafka模块pykafka生产者简单封装代码，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧

  3. 所属分类：其它

    • 发布日期：2020-09-18
    • 文件大小：33kb
    • 提供者：weixin_38547409

  1. python3连接kafka模块pykafka生产者简单封装代码

  2. 1.1安装模块 pip install pykafka 1.2基本使用 # -* coding:utf8 *- from pykafka import KafkaClient host = 'IP:9092, IP:9092, IP:9092' client = KafkaClient(hosts = host) # 生产者 topicdocu = client.topics['my-topic'] producer = topicdocu.get_producer() for i in r

  3. 所属分类：其它

    • 发布日期：2020-12-23
    • 文件大小：40kb
    • 提供者：weixin_38658564

  1. sparkStreaming结合kafka取存数据

  2. 目录 一、说明 1、环境介绍 2、测试业务介绍 3、目的 二、理论基础 1、低效率的代码 2、这样提升效率和灵活性 (1)对KafkaProducer进行封装便于广播 (2)初始化KafkaSink,并广播 (3)使用广播变量发送数据到Kafka 三、完整业务程序展示 1、配置文件sparkStreaming.properties 2、动态加载配置文件LoadParameter类 3、主程序Kafka2SparkStreaming2Kafka 四、启动程序测试 1、创建相关kafka主题 2、k

  3. 所属分类：其它

    • 发布日期：2021-01-07
    • 文件大小：64kb
    • 提供者：weixin_38531788

  1. mega-go-micro:基于go-micro v2封装的golang微服务框架，请谨慎使用-源码

  2. 基础组件服务 提供mysql，redis，mongo.consul，kafka等服务的连接池提供工具函数 安装 go get github.com/hammercui/mega-go-micro 常问问题 1 etcd err：go mod使用gprc 1.26.0 replace google.golang.org/grpc => google.golang.org/grpc v1.26.0

  3. 所属分类：其它

    • 发布日期：2021-03-30
    • 文件大小：184kb
    • 提供者：weixin_42107491
« 12 »