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

搜索资源列表

  1. flumee.zip

  2. 文章《利用Flume拦截器（interceptors）实现Kafka Sink的自定义规则多分区写入》所需的代码和jar包。这里吐槽一下CSDN，上传个文件还必须填这填那的，不填还不行，关键词长度还超出了限制，烦不烦人啊。。。。。。。。。

  3. 所属分类：Java

    • 发布日期：2017-08-03
    • 文件大小：36864
    • 提供者：m0_37739193

  1. IT十八掌_kafka阶段学习笔记(课堂笔记与原理图解)

  2. IT十八掌第三期配套笔记! 1、kafka消息系统的介绍 2、producer有分区类 3、kafka支持的副本模式 4、kafka消费者偏移量考察 5、kafka自定义消费者 6、kafka自定义生产者 7、kafka带分区生产者 8、flume集成kafka的几种方式

  3. 所属分类：kafka

    • 发布日期：2017-09-03
    • 文件大小：123904
    • 提供者：chajuexiu4867

  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. Apache_Kafka_Share

  2. Kafka是由LinkedIn公司用Scala语言开发的，一个分布式、分区的、多副本的、多订阅者的，基于Zookeeper协调的分布式日志系统(也可做MQ系统)。主要初衷目标是构建一个用来处理海量日志，用户行为和网站运营统计等的数据处理框架。 Kafka的特性及优势 1. 高吞吐率，kafka的高吞吐率是秒杀其他消息系统的，原因在批处理，压缩，多分区 等。 2. 高性能，MQ系统的性能瓶颈主要在于持久化和对消息消费的ack。kafka的持久化策略 采用文件系统以及page cache，消息直接

  3. 所属分类：其它

    • 发布日期：2018-11-19
    • 文件大小：1048576
    • 提供者：clouds668

  1. kafkatool.exe

  2. Kafka Tool是一个用于管理和使用Apache Kafka集群的GUI应用程序。它提供了一个直观的UI，允许用户快速查看Kafka群集中的对象以及存储在群集主题中的消息。它包含面向开发人员和管理员的功能。一些主要功能包括 快速查看所有Kafka集群，包括其经纪人，主题和消费者 查看分区中消息的内容并添加新消息 查看 Kafka消费者的偏移，包括Apache Storm Kafka鲸鱼消费者 以漂亮的格式显示JSON和XML消息 添加和删​​除主题以及其他管理功能 将 Kafka分区中的单

  3. 所属分类：kafka

    • 发布日期：2019-06-03
    • 文件大小：51380224
    • 提供者：qingai521

  1. kafka自定义partition分发策略实例代码.zip

  2. kafka版本:kafka_2.11-0.9.0.1 kafka jar包版本:0.9.0.1 kafka集群:192.168.1.101,192.168.1.102,192.168.1.103 partition分发策略主要是自定义Partitioner的实现类,通过根据key和分区数量来实现

  3. 所属分类：Java

    • 发布日期：2019-09-26
    • 文件大小：13312
    • 提供者：ssxueyi

  1. springboot整合kafka，指定分区发送，批量消费，指定topic分区消费

  2. springboot2.x整合kafka，发送者包含自定义分区发送，发送之后的回调函数，消费者有两个监听，一个是批量消费多topic，另外一个是消费指定topic的不同分区

  3. 所属分类：Java

    • 发布日期：2019-09-26
    • 文件大小：62464
    • 提供者：qq_33355821

  1. 基于支付场景下的微服务改造与性能优化

  2. 近年来微服务架构已经成为大规模分布式架构的主流技术，越来越多的公司已经或开始转型为微服务架构。本系列不以某一种微服务框架的使用为主题，而是对整个微服务生态进行系统性的讲解，并结合工作中的大量实战案例，让读者读完即可实际上手应用。(1)对接业务层:主要是一些业务系统对接支付系统,包括电商业务、互金业务和一键支付三 个限界上下文 (2)统一接入网关层:主要功能是对请求入口进行加解密、分流、限流和准入控制等。 上下文 电商业务 互金业务 一键支付 运营服务 统一接入层 支撑服务 加签、验签、分流、限流

  3. 所属分类：微服务

    • 发布日期：2019-06-30
    • 文件大小：1048576
    • 提供者：longlongriver

  1. flumen的aken.jar

  2. fluem的自定义jar包,kafka的分区和拦截器

  3. 所属分类：互联网

    • 发布日期：2020-07-10
    • 文件大小：4096
    • 提供者：aino0613

  1. Java kafka如何实现自定义分区类和拦截器

  2. 主要介绍了Java kafka如何实现自定义分区类和拦截器,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

  3. 所属分类：其它

    • 发布日期：2020-08-19
    • 文件大小：62464
    • 提供者：weixin_38594252

  1. self-entertainment:在线花店，消息中间件，springcloud，spring，sharding-jdbc，springboot，netty源码，vue，elasticsearch，lucene，mybatis，jpa-源

  2. 自我娱乐 项目模块简介 activemq模块主要是测试消息中间件的一些特性，包括持久订阅，连续/定时投递，死信变量，kafka的生产者和消费者，指定位置自定义读取主题，了解分区和分组机制 amazingt是一个常用的springweb工程，包括aop，自定义注释解，springmvc，jpa + hibernate，springlistener，预定定时任务，过滤器的简单实用，包括简单的登录权限验证，设备crud功能 cloud模块没得说，主要是亲手建造一整套springcloud服务，包括常用

  3. 所属分类：其它

    • 发布日期：2021-03-24
    • 文件大小：896000
    • 提供者：weixin_42099987

  1. kafka-java-api-lab-源码

  2. 卡夫卡课程的测试项目 该项目包含通过Java API使用Kafka的不同示例。 关于kafka的信息 话题 主题在文件中包含日志更改消息。 拓扑由至少一个分区组成。 消息由键和值组成。 消息分布在分区中，分布是通过算法完成的。 该算法可循环，杂音3或自定义（实现特定类）。 这些算法将使用密钥作为输入来确定每个消息的位置（在分区中）。 因此，相同的密钥将始终位于同一分区中。 隔断 一个分区由单个代理程序管理，但将取决于复制因素，将其复制到其他代理程序。 因此，其中一个代理将具有分区负责人，

  3. 所属分类：其它

    • 发布日期：2021-02-12
    • 文件大小：20971520
    • 提供者：weixin_42113380

  1. rust-rdkafka：基于librdkafka的Rust的完全异步的，基于期货的Kafka客户端库-源码

  2. 锈-rdkafka 基于Rust的完全异步的，启用了客户端库。 图书馆 rust-rdkafka为rust-rdkafka提供了一个安全的Rust接口。 master分支当前基于librdkafka 1.5.3。 文献资料 产品特点 目前提供的主要功能是： 自0.8.x起支持所有Kafka版本。 有关代理兼容性选项的更多信息，请。 消耗单个或多个主题。 消费者自动重新平衡。 可自定义的重新平衡，带有预平衡和后平衡。 同步或异步消息生成。 可自定义的偏移量提交。 创建和删除主题以及

  3. 所属分类：其它

    • 发布日期：2021-02-05
    • 文件大小：152576
    • 提供者：weixin_42111465

  1. kafdrop：Kafka Web UI-源码

  2. Kafdrop – Kafka Web UI Kafdrop是一个Web UI，用于查看Kafka主题和浏览消费者组。 该工具显示诸如代理，主题，分区，使用者之类的信息，并允许您查看消息。 该项目是Kafdrop 2.x的重新启动，它被踢到JDK 11 +，Kafka 2.x，Helm和Kubernetes的世界中。 它是一个运行在Spring Boot上的轻量级应用程序，易于配置，支持SASL和TLS安全的代理。 产品特点 查看Kafka代理-主题和分区分配以及控制器状态 查看主题-分区数

  3. 所属分类：其它

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

  1. streamx：kafka-connect-s3：从Kafka到对象存储（s3）提取数据-源码

  2. 基于安全问题，已计划此REPO SEC故障单＃SEC-2988 StreamX：Kafka Connect for S3 从很棒的 StreamX是基于kafka连接的连接器，用于将数据从Kafka复制到对象存储，例如Amazon s3，Google Cloud Storage和Azure Blob存储。 它专注于可靠和可扩展的数据复制。 它可以以不同的格式（如镶木地板）写出数据，以便分析工具可以轻松使用它，也可以满足不同的分区要求。 ＃＃产品特点 ： StreamX从kafka-conn

  3. 所属分类：其它

    • 发布日期：2021-01-30
    • 文件大小：252928
    • 提供者：weixin_42126668

  1. kafka-ui:用于Apache Kafka管理的开源Web GUI-源码

  2. Kafka UI – Kafka的免费Web UI Kafka UI是一个免费的开源Web UI，用于监视和管理Apache Kafka集群。 Kafka UI是一个简单的工具，可让您观察到数据流，帮助更快地查找和排除问题并提供最佳性能。 它轻巧的仪表板使您可以轻松跟踪Kafka集群的关键指标-代理，主题，分区，生产和消费。 仅需几个简单的命令即可设置Kafka UI，从而以一种易于理解的方式可视化您的Kafka数据。 您可以在本地或在云中运行该工具。 特征 多集群管理—集中监视和管理所有

  3. 所属分类：其它

    • 发布日期：2021-03-29
    • 文件大小：699392
    • 提供者：weixin_42132325