没有合适的资源？快使用搜索试试~ 我知道了~

文库首页开发技术其它druid-kafka-ext:Druid Kafka扩展可避免Kafka高级API重新平衡问题

druid-kafka-ext:Druid Kafka扩展可避免Kafka高级API重新平衡问题

共48个文件

java：43个

xml：2个

md：2个

Java

需积分: 6 0 下载量 54 浏览量 2021-04-29 12:06:46 上传评论收藏 80KB ZIP 举报

温馨提示

卡夫卡八 Kafka-eight-ex提供了一个使用kafka低级api的德鲁伊摄取扩展。更改重新平衡策略以减少发生重新平衡时的重复事件。经测试的德鲁伊版本为0.7.1.1，卡夫卡版本为0.8.2.1

资源推荐

资源详情

资源评论

MartinHub-notes：:hundred_points:大数据开发笔记（包括：Hadoop，Hive，HBase，Phoenix，Scala，Spark，Flink，Kafka，Azkaban，Flume，Sqoop，Oozie，DataX等）。Java开发笔记（Java基础，Spring Boot， Spring Cloud，Spring Security，MyBatis-plus，Swagger-UI，Druid，JWT，Lombok）

MartinHub的学习笔记关于我 MartinHub :smiling_face_with_sunglasses: ，，热爱生活！热爱技术！微信公众号【MartinHub】个人微信号【MartinHub】项目介绍大数据 Java ... :black_nib:本仓库有来源自己总结，网上...

Apache Druid:高性能实时分析数据库-开源

Druid 从 Kafka 和 Amazon Kinesis 等消息总线流式传输数据，并从 HDFS 和 Amazon S3 等数据湖批量加载文件。 Druid 支持最流行的结构化和半结构化数据文件格式。 Druid 已经过基准测试，其性能大大优于传统解决...

messagepackKafkaSerde:Kafka序列化器反序列化器，可与MessagePack格式的消息一起使用，并将其反序列化为JSON，然后序列化为Byte数组，该数组打算在Apache Druid数据库中使用

MsgPack Kafka序列化/反序列化出版要交叉发布多个scala版本： sbt +publish

13天玩转千亿级数仓项目视频教程（离线+实时）

5星 · 资源好评率100%

7.Druid的安装和使用 8.流式数仓实现适用人群： 1、对企业级数据仓库构建感兴趣，有一定大数据基础。 2、对目前职业有进一步提升要求，希望从事数据行业高薪工作的在职人员。 3、对数据行业感兴趣的相关人员。基础...

滴滴出行实时计算系统架构及实践

4星 · 用户满意度95%

（1）可扩展性（2）有状态的实时计算（3）数据被重复处理（4）高可用（5）实时数据流与外部系统或服务关联计算 2. OLAP系统架构选型:KV store与column store 哪种存储更适合OLAP应用？ 3. 简要介绍Kafka的特性，...

java8源码-becoming-programming-god:成为编程之神，记录所有技术难点，梳理个人技术栈，从编程语言到分布式系统，到服

druid 2.13 guava 2.14 curator 3.15 apache commons 3. 读书笔记(comment) 3.1 Java编程思想 3.2 算法 3.3 设计模式 3.4 Java8实战(java8) 3.5 深入剖析Tomcat 3.6 Mysql技术内幕 3.7 高性能mysqlss 3.8 Kafka权威...

LogAnalyzer:分析大数据组件的客户日志，例如HDFS，Hive，HBase，Yarn，MapReduce，Storm，Spark，Spark 2，Knox，Ambari Metrics，Nifi，Accumulo，Kafka，Flume，Oozie，Falcon，Atlas和Zookeeper

日志分析器-分析大数据组件的客户日志，例如HDFS，Hive，HBase，Yarn，MapReduce，Storm，Spark，Spark 2，Knox，Ambari Metrics，Nifi，Accumulo，Kafka，Flume，Oozie，Falcon，Atlas和Zookeeper。内部架构分析...

docker-druid:德鲁伊在docker中，也在mesos上

德鲁伊在码头工人基本映像用于烘焙您自己的配置。支持在运行的基本映像。该图像也应该用作基础。以kafka作为实时输入并以hdfs作为深度存储的示例集群，可在boot2docker中运行。

基于spring boot的小区物业管理系统源码+论文+答辩ppt

tomcat 8.5.100

tomcat 8.5.100

自主研发的软著申请代码文档整理输出工具

5星 · 资源好评率100%

可在软著申请时使用的代码文档整理输出工具，可选择多个特定目录，设置多类型文件，指定选择生成代码文档，可操作性很好，并且在生成word代码文档时，过滤了所有空白行和注释，过滤的注释类型涵盖mysql、java、php、python、js、html、node、vue等所有大类语言。软件环境：win10、win7、win8、win xp 更新日志： 2022年6月1日：更新了动态进度展示，无响应超时等

毕业设计-基于JAVA的springboot超市进销存系统(源代码+论文）

4星 · 用户满意度95%

本超市进销存系统以springboot作为框架，b/s模式以及MySql作为后台运行的数据库，同时使用Tomcat用为系统的服务器。本系统主要包括首页、个人中心、员工管理、客户管理、供应商管理、承运商管理、仓库信息管理、商品类别管理、商品信息管理、采购信息管理、入库信息管理、出库信息管理、销售订单管理、部门管理、岗位管理等功能，通过这些功能的实现基本能够满足日常超市进销存管理的操作。通过这个系

Java 面经手册·小傅哥.pdf

5星 · 资源好评率100%

这是一本以面试题为入口讲解 Java 核心内容的技术书籍，书中内容极力的向你证实代码是对数学逻辑的具体实现。当你仔细阅读书籍时，会发现Java中有大量的数学知识，包括：扰动函数、负载因子、拉链寻址、开放寻址、斐波那契（Fibonacci）散列法还有黄金分割点的使用等等。适合人群 1. 具备一定编程基础，工作1-3年的研发人员 2. 想阅读 Java 核心源码，但总感觉看不懂的 3. 看了太多

JAVA课程设计，学生管理系统，设计SQL server数据库操作

项目文件分为10个部分：首先有两个窗口：管理员登录窗口以及实现其他功能的总窗口；其次就是查找类、插入类、浏览类、修改类这四个项目核心类，最后这四个核心实现类又一一对应这四个函数：查找、插入、浏览（查看）、修改，共10个部分在同一个package中，故对于访问权限问题没有过于重视，大部分都为友好类或者友好方法，具体实现方式下文有具体解释，故在此不在详述。

BurpLoaderKeygen.jar.zip

网络安全-02-BurpSuite工具详细安装教程 BurpSuite注册机下载激活-BurpSuite工具将BurpLoaderKeygen.jar & burpsuite_pro_v2023.4.5.jar 放置同一目录下 3.3.2 cmd命令行执行 java -jar BurpLoaderKeygen.jar >java -jar BurpLoaderKeygen.jar

java-11 windows-x64 安装包

java-11 windows-x64 安装包，免去外网下载慢的问题

2024最强Java面试八股文

5星 · 资源好评率100%

《2024最强Java面试八股文》是一份针对Java面试的全面指南，内容涵盖JVM、MQ、MyBatis、MySQL、Redis、Spring Boot、Spring Cloud以及设计模式等多个方面。这份资料旨在帮助求职者系统地复习和掌握Java及相关技术的核心知识点，从而在面试中取得更好的成绩。该资源不仅适用于校招，也适用于社招。无论您是一名即将毕业的学生还是已经有一定工作经验的开发者，都

Java面试八股文2023最新版

5星 · 资源好评率100%

工作了一年多想跳槽了，自己整理的Java面试八股文 java面试题 2023最新整理 java八股文高频面试题里边包含了很多领域的java se基础、springboot springcloud MyBatis、ZooKeeper、Dubbo、Elasticsearch、Memcached、 Redis、MySQL、Spring、tomcat、Git、 Linux Nginx,以及软实力等

JDK1.8 windows 64位

JDK1.8 windows 64位

Spire.Doc for Java 11.4.2 全功能无限制

5星 · 资源好评率100%

本资资打包重新shade package name : com.sini，官网例子已测试通过

m3u8文件合并为mp4（适用于uc浏览器下载的，带有密钥key的也可以用）

下载的m3u8文件（一个m3u8文件和一个对应的文件夹），想要转为mp4，可以使用该小工具环境要求： 1. 需要配置有jre1.8，可以网上搜索如何安装，安装后要配置好环境变量适用文件： 1. m3u8对应的文件夹里，都是没有后缀名的文件，用0， 1，2，3……来命名。 2. 其中可能会有0.key之类的文件（也可能没有），该文件是密钥文件，是有用的 3. 如果有不是0， 1，2，3……来

收起资源包目录

druid-kafka-ext-master.zip （48个子文件）

druid-kafka-ext-master

kafka-eight-ex

pom.xml 3KB

src

test

java

druid

firehose

kafka

support

KafkaIngestConsumer.java 5KB

SimpleTwoPartitioner.java 492B

LocalZookeeperAndKafka.java 776B

MiddleLevelConsumerInLocal.java 5KB

ProducerEx.java 1KB

TestKafkaProducer.java 3KB

TestZookeeperServer.java 2KB

UTGlobal.java 583B

TestKafkaServer.java 2KB

ReflectFieldUtil.java 2KB

SimplePartitioner.java 467B

TestKafkaMessageSerializer.java 740B

KafkaMessageSerializer.java 538B

KafkaZKInfoTest.java 6KB

MiddleLevelConsumer.java 5KB

lowlevelapi

test

FullGc.java 1009B

KafkaLowLevelApiTest.java 14KB

main

resources

META-INF

services

io.druid.initialization.DruidModule 58B

log4j.xml 2KB

java

com

ebay

pulsar

druid

firehose

kafka

KafkaEightDruidModule.java 1KB

KafkaEightFirehoseFactory.java 7KB

support

SimpleConsumerController.java 18KB

DefaultPartitionCoordinator.java 2KB

ConsumerPartitionReader.java 14KB

data

KafkaZKData.java 33KB

ConsumerId.java 3KB

KafkaConsumerConfig.java 1KB

RebalanceResult.java 2KB

BasePartitionCoordinator.java 6KB

exceptions

KafkaPartitionReaderClosedException.java 632B

KafkaPartitionReaderException.java 839B

KafkaZKException.java 716B

api

PartitionReader.java 2KB

AssignorContext.java 862B

KafkaConsumer.java 2KB

SimpleController.java 2KB

PartitionCoordinatorStrategy.java 2KB

ZKConnector.java 5KB

util

TopicCount.java 8KB

JSON.java 1KB

NameableThreadFactory.java 1KB

LOG.java 1KB

PropertiesUtils.java 1KB

DefaultAssignorContext.java 1KB

SimpleConsumerEx.java 20KB

LICENSE.md 12KB

README.md 264B

共 48 条

评论收藏

内容反馈

资源评论

资源反馈

评论星级较低，若资源使用遇到问题可联系上传者，3个工作日内问题未解决可申请退款~

无分别

粉丝: 22
资源: 4574

上传资源快速赚钱

我的内容管理展开

我的资源快来上传第一个资源

我的收益

登录查看自己的收益

我的积分登录查看自己的积分

我的C币登录后查看C币余额

我的收藏

我的下载

下载帮助

前往需求广场，查看用户热搜

druid-kafka-ext:Druid Kafka扩展可避免Kafka高级API重新平衡问题

ssm+Druid+kafka

druid-metrics-to-kafka:将Druid指标发送到Kafka主题

Spring-Mybatis-Druid-Kafka示例集成Example

kafka-spark-streaming-druid:将卡夫卡流带入火花，应用变换并沉入德鲁伊。 一切都Dockerized

3、Druid的load data 示例（实时kafka数据和离线-本地或hdfs数据）

Druid使用教程.md

滴滴在小程序方向上的探索和实践

Apache Druid:高性能实时分析数据库-开源

messagepackKafkaSerde:Kafka序列化器反序列化器，可与MessagePack格式的消息一起使用，并将其反序列化为JSON，然后序列化为Byte数组，该数组打算在Apache Druid数据库中使用

13天玩转千亿级数仓项目视频教程（离线+实时）

滴滴出行实时计算系统架构及实践

java8源码-becoming-programming-god:成为编程之神，记录所有技术难点，梳理个人技术栈，从编程语言到分布式系统，到服

LogAnalyzer:分析大数据组件的客户日志，例如HDFS，Hive，HBase，Yarn，MapReduce，Storm，Spark，Spark 2，Knox，Ambari Metrics，Nifi，Accumulo，Kafka，Flume，Oozie，Falcon，Atlas和Zookeeper

docker-druid:德鲁伊在docker中，也在mesos上

基于spring boot的小区物业管理系统源码+论文+答辩ppt

tomcat 8.5.100

最新Java JDK 8安装版（Windows 64位）

自主研发的软著申请代码文档整理输出工具

毕业设计-基于JAVA的springboot超市进销存系统(源代码+论文）

Java 面经手册·小傅哥.pdf

JAVA课程设计，学生管理系统，设计SQL server数据库操作

BurpLoaderKeygen.jar.zip

java-11 windows-x64 安装包

2024最强Java面试八股文

Java面试八股文2023最新版

JDK1.8 windows 64位

Spire.Doc for Java 11.4.2 全功能无限制

m3u8文件合并为mp4（适用于uc浏览器下载的，带有密钥key的也可以用）

最新资源

kafka-spark-streaming-druid:将卡夫卡流带入火花，应用变换并沉入德鲁伊。一切都Dockerized