- kafka大小:8KB这是使用java操作kafka consumer api的一个demo,欢迎下载交流,博客地址:https://blog.csdn.net/qq_26803795这是使用java操作kafka consumer api的一个demo,欢迎下载交流,博客地址:https://blog.csdn.net/qq_268037950 269浏览会员免费
- storm大小:22MB介绍 今天接上文,来实现一个Storm数据流处理综合案例的第二部分,Storm集群向Kafka集群源源不断读取数据,通过MyBatis写入到MySQL数据库,并部署为远程模式 准备工作 参考上文准备工作 代码编写 思路:Storm集群从Kafkatopic主题获取数据,解析后写入MySQL,注意我们使用MyBatis工具与数据库交互 项目结构 部署MySQL 我们在服务器上部署一台MySQL数据库 具体参考这篇文章 数据库表结构如下: WordCountDao 该类会获取SqlSessionConfig配置类的SqlSessionFactory和WordCountMapper的接口方法,生成具体与数据库交互的Session WordCountMapper.xml 该文件为MyBatis编写与数据库交互的具体SQL代码的地方 具体实现了全量查询和批量更新或插入的接口功能介绍 今天接上文,来实现一个Storm数据流处理综合案例的第二部分,Storm集群向Kafka集群源源不断读取数据,通过MyBatis写入到MySQL数据库,并部署为远程模式 准备工作 参考上文准备工作 代码编写 思路:Storm集群从Kafkatopic主题获取数据,解析后写入MySQL,注意我们使用MyBatis工具与数据库交互 项目结构 部署MySQL 我们在服务器上部署一台MySQL数据库 具体参考这篇文章 数据库表结构如下: WordCountDao 该类会获取SqlSessionConfig配置类的SqlSessionFactory和WordCountMapper的接口方法,生成具体与数据库交互的Session WordCountMapper.xml 该文件为MyBatis编写与数据库交互的具体SQL代码的地方 具体实现了全量查询和批量更新或插入的接口功能0 107浏览会员免费
- kafka大小:11MBKafka版本2.5.0编译后的源码,可以直接用idea或者eclipse导入。0积分,欢迎下载!凑够50字。。。Kafka版本2.5.0编译后的源码,可以直接用idea或者eclipse导入。0积分,欢迎下载!凑够50字。。。0 118浏览会员免费
- elasticsearch大小:87MBelasticsearch-6.3.0.tarelasticsearch-6.3.0.tar0 80浏览会员免费
- kafka大小:16KBjava开发的基于kafka、xlog的web日志实时分析storm topology storm-kafka-xlog 使用java语言开发的基于storm、kafka、xlog的web日志实时分析系统,实时分析指定时间周期内web日志中每个ip访问的各项数据指标(访问总次数,动、静态次数,GET、POST、HEAD等请求类型次数,HTTP状态码各种状态前缀次数,访问广度、sql注入和xss检测可疑度、useragent个数、是否使用代理访问),可通过设置web日志指定字段的阀值选择性的记录分析结果到mysql数据库,通过分析数据能够做很多事情,比如判断拦截恶意访问ip,了解网站访问情况,对sql注入和xss跨站进行检测。 编译 mvn clean package 生成包路径 target/storm-xlog-version-jar-with-dependencies.jar 创建数据库 库名可以自己定,导入storm_xlog.sql文件中的ips表结构 配置 #zookeeper.server地址,多个逗号分隔 xlog.zookeeper.serjava开发的基于kafka、xlog的web日志实时分析storm topology storm-kafka-xlog 使用java语言开发的基于storm、kafka、xlog的web日志实时分析系统,实时分析指定时间周期内web日志中每个ip访问的各项数据指标(访问总次数,动、静态次数,GET、POST、HEAD等请求类型次数,HTTP状态码各种状态前缀次数,访问广度、sql注入和xss检测可疑度、useragent个数、是否使用代理访问),可通过设置web日志指定字段的阀值选择性的记录分析结果到mysql数据库,通过分析数据能够做很多事情,比如判断拦截恶意访问ip,了解网站访问情况,对sql注入和xss跨站进行检测。 编译 mvn clean package 生成包路径 target/storm-xlog-version-jar-with-dependencies.jar 创建数据库 库名可以自己定,导入storm_xlog.sql文件中的ips表结构 配置 #zookeeper.server地址,多个逗号分隔 xlog.zookeeper.ser0 15浏览会员免费
- openrest+lua+ngi大小:23KB实现openresty+lua+nginx+kafka,nginx接收请求后经lua处理实时写入kafka,该压缩包为lua调用kafka的依赖包实现openresty+lua+nginx+kafka,nginx接收请求后经lua处理实时写入kafka,该压缩包为lua调用kafka的依赖包0 45浏览会员免费
- Kafka大小:59MB使用Kafka的小伙伴,有没有为无法直观地查看 Kafka 的 Topic 里的内容而发过愁呢? 此版本为window64位,安装简单快捷使用Kafka的小伙伴,有没有为无法直观地查看 Kafka 的 Topic 里的内容而发过愁呢? 此版本为window64位,安装简单快捷0 100浏览会员免费
- kafka大小:7KBkafka使用kafka实现的java版时间轮.zip 使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafkakafka使用kafka实现的java版时间轮.zip 使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka实现的java版时间轮.zip使用kafka0 8浏览免费
- kafka大小:68MBApache Kafka 2.8.1 (Scala 2.13 :kafka_2.13-2.8.1.tgz) 是一个开源分布式事件流平台,被数千家公司用于高性能数据管道、流分析、数据集成和关键任务应用程序。) 是一个开源分布式事件流平台,被数千家公司用于高性能数据管道、流分析、数据集成和关键任务应用程序。Apache Kafka 2.8.1 (Scala 2.13 :kafka_2.13-2.8.1.tgz) 是一个开源分布式事件流平台,被数千家公司用于高性能数据管道、流分析、数据集成和关键任务应用程序。) 是一个开源分布式事件流平台,被数千家公司用于高性能数据管道、流分析、数据集成和关键任务应用程序。0 201浏览¥ 9.90
- kubernetes大小:49MB基于Kubernetes(k8s)实现的管理平台是一种利用Kubernetes这一开源容器编排平台来管理和自动化应用程序部署、扩展和运维的工具。Kubernetes提供了一个用于自动部署、扩展和管理容器化应用程序的系统,它通过简化和自动化这些过程,帮助企业更高效地管理其应用程序生命周期。 在这样的管理平台中,Kubernetes的核心特性包括容器编排、服务发现、负载均衡、自动扩展、滚动更新和自我修复等。这些特性使得开发和运维团队能够快速响应市场变化,灵活地部署和调整资源,同时保持系统的高可用性和稳定性。 容器编排是Kubernetes管理平台的核心功能之一,它允许用户定义和运行多容器应用程序,这些容器可以跨多个主机进行调度和管理工作。通过这种方式,Kubernetes能够确保应用程序的各个组件能够按照预期协同工作,同时也能够灵活地应对单个容器或主机的故障。 服务发现和负载均衡是Kubernetes管理平台的另外两个重要特性。服务是Kubernetes中的一个抽象,它定义了一种访问一组相同容器的方式,而负载均衡则确保了流量可以均匀地分配到这些容器上。基于Kubernetes(k8s)实现的管理平台是一种利用Kubernetes这一开源容器编排平台来管理和自动化应用程序部署、扩展和运维的工具。Kubernetes提供了一个用于自动部署、扩展和管理容器化应用程序的系统,它通过简化和自动化这些过程,帮助企业更高效地管理其应用程序生命周期。 在这样的管理平台中,Kubernetes的核心特性包括容器编排、服务发现、负载均衡、自动扩展、滚动更新和自我修复等。这些特性使得开发和运维团队能够快速响应市场变化,灵活地部署和调整资源,同时保持系统的高可用性和稳定性。 容器编排是Kubernetes管理平台的核心功能之一,它允许用户定义和运行多容器应用程序,这些容器可以跨多个主机进行调度和管理工作。通过这种方式,Kubernetes能够确保应用程序的各个组件能够按照预期协同工作,同时也能够灵活地应对单个容器或主机的故障。 服务发现和负载均衡是Kubernetes管理平台的另外两个重要特性。服务是Kubernetes中的一个抽象,它定义了一种访问一组相同容器的方式,而负载均衡则确保了流量可以均匀地分配到这些容器上。0 15浏览会员免费
- kafka_manager2.0大小:92MBkafka_manager2.0.0.2编译后的版本,无需sbt编译,解压直接使用,拜托sbt(死变态)痛苦下载,kafka管理神器kafka_manager2.0.0.2编译后的版本,无需sbt编译,解压直接使用,拜托sbt(死变态)痛苦下载,kafka管理神器0 62浏览会员免费
- kafka大小:59KB适用于初学者接触kafka适用于初学者接触kafka0 17浏览¥ 9.90
- kafka-manage大小:92MB通过scala和sbt编译好的最新版kafka-manager-2.0.0.2.zip,可以直接解压使用通过scala和sbt编译好的最新版kafka-manager-2.0.0.2.zip,可以直接解压使用0 23浏览会员免费
- Simplx大小:35MBSimplx Document, generated by doxgen and dot. About Simplx is a C++ development framework for building reliable cache-friendly distributed and concurrent multicore software. Simplx was developped by Tredzone SAS. We provide software technology solutions and services dedicated to high-performance real-time processing. Our technology enables low and predictable latency, scalability, and high throughput. We also offer support contracts and enterprise tools for monitoring, profiling, debugging, server clustering under commercial licenses. Simplx is used at the Paris stock exchange by Euronext's market exchange platform, called "Optiq", and has been successfully deployed since November 2016. Tredzone was founded in 2013 and operates in France, the UK and US. License Simplx is open-sourced under the Apache 2.0 license, please see the file "LICENSE" in our github repo.Simplx Document, generated by doxgen and dot. About Simplx is a C++ development framework for building reliable cache-friendly distributed and concurrent multicore software. Simplx was developped by Tredzone SAS. We provide software technology solutions and services dedicated to high-performance real-time processing. Our technology enables low and predictable latency, scalability, and high throughput. We also offer support contracts and enterprise tools for monitoring, profiling, debugging, server clustering under commercial licenses. Simplx is used at the Paris stock exchange by Euronext's market exchange platform, called "Optiq", and has been successfully deployed since November 2016. Tredzone was founded in 2013 and operates in France, the UK and US. License Simplx is open-sourced under the Apache 2.0 license, please see the file "LICENSE" in our github repo.0 100浏览会员免费
- kafka大小:90MBkafka和zookeeper安装包kafka和zookeeper安装包0 209浏览会员免费
- kafka大小:3KBkafkaApache Kafka是一个分布式流式计算平台,它主要用于处理实时的数据流。在大部分企业开发人员中,Kafka常被用作一个分布式消息队列,而较少利用其流式计算功能。 Kafka的特性主要包括: 消息文件存储(消息堆积能力):Kafka具有很强的消息堆积能力,可以存储大量的消息。 消息topic分区:为了实现扩展性,一个非常大的topic可以分布到多个broker(即服务器)上,一个topic可以分为多个partition,每个partition是一个有序的队列。 消息顺序的保证:在每个partition内部,消息是按照发送的顺序进行存储的,这保证了消息的有序性。 拉模型(消费者水平扩展):Kafka采用拉模型进行消息的消费,消费者可以根据自己的处理能力来拉取消息,实现了消费者的水平扩展。kafkaApache Kafka是一个分布式流式计算平台,它主要用于处理实时的数据流。在大部分企业开发人员中,Kafka常被用作一个分布式消息队列,而较少利用其流式计算功能。 Kafka的特性主要包括: 消息文件存储(消息堆积能力):Kafka具有很强的消息堆积能力,可以存储大量的消息。 消息topic分区:为了实现扩展性,一个非常大的topic可以分布到多个broker(即服务器)上,一个topic可以分为多个partition,每个partition是一个有序的队列。 消息顺序的保证:在每个partition内部,消息是按照发送的顺序进行存储的,这保证了消息的有序性。 拉模型(消费者水平扩展):Kafka采用拉模型进行消息的消费,消费者可以根据自己的处理能力来拉取消息,实现了消费者的水平扩展。0 18浏览会员免费
- kafka-eagle1.43源大小:10MBkafka-eagle-1.4.3 .zip源码包直接build.sh编译,安装配置参考地址https://blog.csdn.net/qq_19524879/article/details/82848797kafka-eagle-1.4.3 .zip源码包直接build.sh编译,安装配置参考地址https://blog.csdn.net/qq_19524879/article/details/828487970 214浏览会员免费
- 综合资源大小:396MBdruid安装所需压缩文件.zipdruid安装所需压缩文件.zip0 51浏览会员免费
- kafka-manager-2.大小:92MBkafka-manager-2.0.0.2 包 1. sudo vi conf/application.conf 修改kafka-manager.zkhosts列表为自己的zk节点 kafka-manager.zkhosts="node21:2181,node22:2181,node23:2181" 2. 启动 nohup bin/kafka-manager -Dconfig.file=conf/application.conf -Dhttp.port=8080 &kafka-manager-2.0.0.2 包 1. sudo vi conf/application.conf 修改kafka-manager.zkhosts列表为自己的zk节点 kafka-manager.zkhosts="node21:2181,node22:2181,node23:2181" 2. 启动 nohup bin/kafka-manager -Dconfig.file=conf/application.conf -Dhttp.port=8080 &0 61浏览会员免费
- kafka大小:76MBkafka编译后的文件kafka编译后的文件0 95浏览会员免费
- kafka-manager大小:92MB已编译,下载后直接unzip解压到文件夹,需要更改conf下application.conf文件,改kafka-manager.zkhosts="localhost:2181"(自己环境)已编译,下载后直接unzip解压到文件夹,需要更改conf下application.conf文件,改kafka-manager.zkhosts="localhost:2181"(自己环境)0 49浏览会员免费
- kafka大小:4KB比较MQ产品之RabbitMQ与Kafka.zip比较MQ产品之RabbitMQ与Kafka.zip0 175浏览¥ 4.90
- kafka大小:92MBKafka在雅虎内部被很多团队使用,媒体团队用它做实时分析流水线,可以处理高达20Gbps(压缩数据)的峰值带宽。为了简化开发者和服务工程师维护Kafka集群的工作,构建了一个叫做Kafka管理器的基于Web工具,叫做 Kafka Manager。这个管理工具可以很容易地发现分布在集群中的哪些topic分布不均匀,或者是分区在整个集群分布不均匀的的情况。它支持管理多个集群、选择副本、副本重新分配以及创建Topic。同时,这个管理工具也是一个非常好的可以快速浏览这个集群的工具。主要支持以下几个功能: 1、管理几个不同的集群; 2、很容易地检查集群的状态(topics, brokers, 副本的分布, 分区的分布); 3、选择副本; 4、产生分区分配(Generate partition assignments)基于集群的当前状态; 5、重新分配分区。Kafka在雅虎内部被很多团队使用,媒体团队用它做实时分析流水线,可以处理高达20Gbps(压缩数据)的峰值带宽。为了简化开发者和服务工程师维护Kafka集群的工作,构建了一个叫做Kafka管理器的基于Web工具,叫做 Kafka Manager。这个管理工具可以很容易地发现分布在集群中的哪些topic分布不均匀,或者是分区在整个集群分布不均匀的的情况。它支持管理多个集群、选择副本、副本重新分配以及创建Topic。同时,这个管理工具也是一个非常好的可以快速浏览这个集群的工具。主要支持以下几个功能: 1、管理几个不同的集群; 2、很容易地检查集群的状态(topics, brokers, 副本的分布, 分区的分布); 3、选择副本; 4、产生分区分配(Generate partition assignments)基于集群的当前状态; 5、重新分配分区。0 67浏览会员免费
- kafka大小:66MB关于kafka的学习资料,2.13.2.7.1版本关于kafka的学习资料,2.13.2.7.1版本0 61浏览会员免费
- kafka大小:38MBkafkaUI.zip jar包和 ReadMekafkaUI.zip jar包和 ReadMe0 82浏览免费
- elasticsearch大小:129MBelk框架下linux 64位安装包 elasticsearch-2.4.0.tar.gz kibana-4.5.1-linux-x64.tar.gz logstash-2.3.1.tar.gzelk框架下linux 64位安装包 elasticsearch-2.4.0.tar.gz kibana-4.5.1-linux-x64.tar.gz logstash-2.3.1.tar.gz0 99浏览会员免费
- kafka大小:4MBYou need to have [Gradle](http://www.gradle.org/installation) and [Java](http://www.oracle.com/technetwork/java/javase/downloads/index.html) installed. Kafka requires Gradle 2.0 or higher. Java 7 should be used for building in order to support both Java 7 and Java 8 at runtime.You need to have [Gradle](http://www.gradle.org/installation) and [Java](http://www.oracle.com/technetwork/java/javase/downloads/index.html) installed. Kafka requires Gradle 2.0 or higher. Java 7 should be used for building in order to support both Java 7 and Java 8 at runtime.0 74浏览会员免费
- kafka大小:2MBkafka kafka与sparkStreaming kafka与Scalakafka kafka与sparkStreaming kafka与Scala0 88浏览免费
- kafka大小:93MBkafka-manager 2.0.0.2 编译版本 自己编译 自己在用,kafka-manager 2.0.0.2 编译版本 自己编译 自己在用,0 55浏览会员免费
- sparkstreaming大小:16KBsparkstreaming消费源kafka,做业务逻辑后,转向目的kafka。高性能,无延迟。满足大数据量的转发任务。sparkstreaming消费源kafka,做业务逻辑后,转向目的kafka。高性能,无延迟。满足大数据量的转发任务。0 68浏览会员免费
- kafka大小:18MB搭建kafka 源代码阅读环境的工程文件,解压即可运行。搭建kafka 源代码阅读环境的工程文件,解压即可运行。0 121浏览会员免费
- jar包大小:612MBhive mysql sqoop 业务数据生成hive mysql sqoop 业务数据生成0 108浏览免费
- kafka大小:82MBApache Kafka 3.0.0 (Scala 2.12 :kafka_2.12-3.0.0.tgz) 是一个开源分布式事件流平台,被数千家公司用于高性能数据管道、流分析、数据集成和关键任务应用程序。) 是一个开源分布式事件流平台,被数千家公司用于高性能数据管道、流分析、数据集成和关键任务应用程序。Apache Kafka 3.0.0 (Scala 2.12 :kafka_2.12-3.0.0.tgz) 是一个开源分布式事件流平台,被数千家公司用于高性能数据管道、流分析、数据集成和关键任务应用程序。) 是一个开源分布式事件流平台,被数千家公司用于高性能数据管道、流分析、数据集成和关键任务应用程序。0 190浏览¥ 9.90
- Kafka大小:480MB46-Kafka核心技46-Kafka核心技0 40浏览免费
- kafka大小:75MB05、Kafka用户日志上报实时统计之应用概述05、Kafka用户日志上报实时统计之应用概述0 59浏览会员免费
- kubernetes大小:427MBkubernetes 部署单机版Kafka、zookeeperkubernetes 部署单机版Kafka、zookeeper0 27浏览会员免费
- kafka大小:1MBkafkamanager管理topic,显示latestOffset值,可修改offset值kafkamanager管理topic,显示latestOffset值,可修改offset值0 79浏览会员免费
- kafka大小:13MB大数据平台数据服务框架。实现了Kafka实时数据过滤、清洗、转换、消费,实现了Spark SQL对Redis、MongoDB等非关系型数据库的数据的读写;集成了规则引擎,可基于规则引擎实现客户标签、画像等相关功能。大数据平台数据服务框架。实现了Kafka实时数据过滤、清洗、转换、消费,实现了Spark SQL对Redis、MongoDB等非关系型数据库的数据的读写;集成了规则引擎,可基于规则引擎实现客户标签、画像等相关功能。0 8浏览会员免费
- kafka大小:38MB07、Kafka用户日志上报实时统计之编码实践07、Kafka用户日志上报实时统计之编码实践0 114浏览会员免费
- zookeeper大小:755MB一、二进制安装 1.安装jdk,二进制安装以及yum安装 2.安装zookeeper 3.部署kafka 二、docker安装 1.搭建zookeeper集群 2.搭建kafka集群 3.测试Zookeeper中Kafka节点信息 4.测试Kafka中创建Topic,Zookeeper中的接受情况一、二进制安装 1.安装jdk,二进制安装以及yum安装 2.安装zookeeper 3.部署kafka 二、docker安装 1.搭建zookeeper集群 2.搭建kafka集群 3.测试Zookeeper中Kafka节点信息 4.测试Kafka中创建Topic,Zookeeper中的接受情况0 33浏览免费
- 静态资源大小:5MB基于ElasticSearch的搜房网实战其中的静态资源代码,因为博客再更新,每一章的代码,但是静态资源多,所以只能通过这个方式了,等后期全部代码写好,会再上传代github.基于ElasticSearch的搜房网实战其中的静态资源代码,因为博客再更新,每一章的代码,但是静态资源多,所以只能通过这个方式了,等后期全部代码写好,会再上传代github.0 160浏览会员免费
- 大数据——Kafka大小:11MBKafka是一个分布式的基于发布/订阅模式的消息队列,主要应用于大数据实时处理领域。Kafka是一个分布式的基于发布/订阅模式的消息队列,主要应用于大数据实时处理领域。0 87浏览免费
- kafka大小:1MBkafka简介 kafka-map是使用Java17和React开发的一款kafka可视化工具。 目前支持的功能有: 多集群管理 集群状态监控(分区数量、副本数量、存储大小、offset) 主题创建、删除、扩容(删除需配置delete.topic.enable = true) broker状态监控 消费者组查看、删除 重置offset 消息查询(支持String和json方式展示) 发送消息(支持向指定的topic和partition发送字符串消息) 延迟消息(通过扩展使kafka支持18个级别的延迟消息) 截图 添加集群 集群管理 broker 主题管理 消费组 查看消费组已订阅主题 消费组详情 topic详情——分区 topic详情——broker topic详情——消费组 topic详情——消费组重置offset topic详情——配置信息kafka简介 kafka-map是使用Java17和React开发的一款kafka可视化工具。 目前支持的功能有: 多集群管理 集群状态监控(分区数量、副本数量、存储大小、offset) 主题创建、删除、扩容(删除需配置delete.topic.enable = true) broker状态监控 消费者组查看、删除 重置offset 消息查询(支持String和json方式展示) 发送消息(支持向指定的topic和partition发送字符串消息) 延迟消息(通过扩展使kafka支持18个级别的延迟消息) 截图 添加集群 集群管理 broker 主题管理 消费组 查看消费组已订阅主题 消费组详情 topic详情——分区 topic详情——broker topic详情——消费组 topic详情——消费组重置offset topic详情——配置信息0 18浏览会员免费
- excel大小:55MBexcel数据抽取到kafkaexcel数据抽取到kafka0 41浏览会员免费
- kafka大小:59MBkafkak客户端工具,可以查看kafka队列中消息,方便调试,运维kafkak客户端工具,可以查看kafka队列中消息,方便调试,运维0 39浏览会员免费
- apache大小:1MBapache plusar消息组件编译必须的jar包,编译源码的时候必须,否则编译不会通过apache plusar消息组件编译必须的jar包,编译源码的时候必须,否则编译不会通过0 56浏览会员免费
- springboot大小:21KB可以用来当做一个kafka项目的框架。 本项目里面简单写了单挑信息、批量信息的web接口测试消息发送,并且注入了两个bean,实现KafkaListener两种不同模式{containerFactory="batchFactory"},{containerFactory = "batchFactoryOff"}。可以用来当做一个kafka项目的框架。 本项目里面简单写了单挑信息、批量信息的web接口测试消息发送,并且注入了两个bean,实现KafkaListener两种不同模式{containerFactory="batchFactory"},{containerFactory = "batchFactoryOff"}。0 768浏览¥ 9.90
- kafka大小:49MBKafkaOffsetMonitor-assembly-0.2.0监控器 以及kafka基础文档KafkaOffsetMonitor-assembly-0.2.0监控器 以及kafka基础文档0 53浏览会员免费
- kafka大小:3KBkafkaKafka的特性主要包括: 消息文件存储(消息堆积能力):Kafka具有很强的消息堆积能力,可以存储大量的消息。 消息topic分区:为了实现扩展性,一个非常大的topic可以分布到多个broker(即服务器)上,一个topic可以分为多个partition,每个partition是一个有序的队列。 消息顺序的保证:在每个partition内部,消息是按照发送的顺序进行存储的,这保证了消息的有序性。 拉模型(消费者水平扩展):Kafka采用拉模型进行消息的消费,消费者可以根据自己的处理能力来拉取消息,实现了消费者的水平扩展。kafkaKafka的特性主要包括: 消息文件存储(消息堆积能力):Kafka具有很强的消息堆积能力,可以存储大量的消息。 消息topic分区:为了实现扩展性,一个非常大的topic可以分布到多个broker(即服务器)上,一个topic可以分为多个partition,每个partition是一个有序的队列。 消息顺序的保证:在每个partition内部,消息是按照发送的顺序进行存储的,这保证了消息的有序性。 拉模型(消费者水平扩展):Kafka采用拉模型进行消息的消费,消费者可以根据自己的处理能力来拉取消息,实现了消费者的水平扩展。0 14浏览会员免费
- kafka和zk大小:95MBkafka和zk的安装包,kafka_2.10-0.8.2.1和kafka_2.11-1.0.1和zookeeper-3.4.6kafka和zk的安装包,kafka_2.10-0.8.2.1和kafka_2.11-1.0.1和zookeeper-3.4.60 114浏览会员免费
- Flume大小:162MBFlume二次开发,支持抽取MYSQL Oracle数据库数据 以JSON格式推送至Kafka。Flume二次开发,支持抽取MYSQL Oracle数据库数据 以JSON格式推送至Kafka。0 32浏览会员免费
- kafka大小:9MBkafka-3.2.0-src 包含:asc、sha512 校验文件kafka-3.2.0-src 包含:asc、sha512 校验文件0 51浏览会员免费
- kafka大小:100MBkafka_2.13-3.3.1.tgzkafka_2.13-3.3.1.tgz0 39浏览会员免费
- kafka大小:3KBkafkaKafka的应用场景非常广泛,例如: 实时日志收集和分析:Kafka可以用于收集应用程序生成的日志数据,然后将其发送到不同的消费者(如ELK Stack、Splunk或自定义分析应用程序)以进行实时分析和监控。 事件驱动架构:Kafka可以作为事件源,帮助构建事件驱动架构。生产者将事件发布到Kafka主题,而消费者可以根据需要订阅这些事件,从而实现松耦合的分布式系统。 数据集成:Kafka可以用于将数据从一个应用程序或数据存储传输到另一个应用程序或数据存储。这对于将数据从一个数据库同步到另一个数据库,或将数据从不同的微服务传递给彼此非常有用。 监控和警报:Kafka可以用于实时监控系统的性能和运行状况。 电子商务实时库存管理:电子商务网站可以使用Kafka来跟踪商品库存的变化,并在库存水平低于某个阈值时发送通知,以便及时补充库存。kafkaKafka的应用场景非常广泛,例如: 实时日志收集和分析:Kafka可以用于收集应用程序生成的日志数据,然后将其发送到不同的消费者(如ELK Stack、Splunk或自定义分析应用程序)以进行实时分析和监控。 事件驱动架构:Kafka可以作为事件源,帮助构建事件驱动架构。生产者将事件发布到Kafka主题,而消费者可以根据需要订阅这些事件,从而实现松耦合的分布式系统。 数据集成:Kafka可以用于将数据从一个应用程序或数据存储传输到另一个应用程序或数据存储。这对于将数据从一个数据库同步到另一个数据库,或将数据从不同的微服务传递给彼此非常有用。 监控和警报:Kafka可以用于实时监控系统的性能和运行状况。 电子商务实时库存管理:电子商务网站可以使用Kafka来跟踪商品库存的变化,并在库存水平低于某个阈值时发送通知,以便及时补充库存。0 60浏览会员免费
- kafka大小:84MBApache Kafka 3.1.0 (Scala 2.13 :kafka_2.13-3.1.0.tgz) 是一个开源分布式事件流平台,被数千家公司用于高性能数据管道、流分析、数据集成和关键任务应用程序。) 是一个开源分布式事件流平台,被数千家公司用于高性能数据管道、流分析、数据集成和关键任务应用程序。Apache Kafka 3.1.0 (Scala 2.13 :kafka_2.13-3.1.0.tgz) 是一个开源分布式事件流平台,被数千家公司用于高性能数据管道、流分析、数据集成和关键任务应用程序。) 是一个开源分布式事件流平台,被数千家公司用于高性能数据管道、流分析、数据集成和关键任务应用程序。0 308浏览¥ 9.90
- docker大小:39MB本教程将有助于小白实现从零开始搭建kafka伪分布式集群本教程将有助于小白实现从零开始搭建kafka伪分布式集群0 7浏览会员免费
- 已编译大小:92MBkafka-manager 是一个开源的 kafka 管理工具,挺好用的,且目前找不到更好用的了。 然而一个头疼的问题是,项目的 release 页并没有提供现成的编译结果供下载,想用的话还得自行编译。编译过程既耗时又耗资源,时不时还受墙的影响,有时候我终于编好了,一段时间后要用又不记得放哪儿了。为了给广大群众以及我自己提供方便。kafka-manager 是一个开源的 kafka 管理工具,挺好用的,且目前找不到更好用的了。 然而一个头疼的问题是,项目的 release 页并没有提供现成的编译结果供下载,想用的话还得自行编译。编译过程既耗时又耗资源,时不时还受墙的影响,有时候我终于编好了,一段时间后要用又不记得放哪儿了。为了给广大群众以及我自己提供方便。0 113浏览会员免费
- spark大小:224KBkafka基于kafka和spark streaming和hbase的日志统计分析系统.zip 基于kafka和spark streaming和hbase的日志统计分析系统.zip基于kafka和spark streaming和hbase的日志统计分析系统.zip基于kafka和spark streaming和hbase的日志统计分析系统.zip基于kafka和spark streaming和hbase的日志统计分析系统.zip基于kafka和spark streaming和hbase的日志统计分析系统.zip基于kafka和spark streaming和hbase的日志统计分析系统.zip基于kafka和spark streaming和hbase的日志统计分析系统.zip基于kafka和spark streaming和hbase的日志统计分析系统.zipkafka基于kafka和spark streaming和hbase的日志统计分析系统.zip 基于kafka和spark streaming和hbase的日志统计分析系统.zip基于kafka和spark streaming和hbase的日志统计分析系统.zip基于kafka和spark streaming和hbase的日志统计分析系统.zip基于kafka和spark streaming和hbase的日志统计分析系统.zip基于kafka和spark streaming和hbase的日志统计分析系统.zip基于kafka和spark streaming和hbase的日志统计分析系统.zip基于kafka和spark streaming和hbase的日志统计分析系统.zip基于kafka和spark streaming和hbase的日志统计分析系统.zip0 24浏览免费
- elasti大小:112MBelasticsearch-6.5.0.zip,配置已修改,安装使用可以参考我写的博客,希望帮到你elasticsearch-6.5.0.zip,配置已修改,安装使用可以参考我写的博客,希望帮到你0 73浏览会员免费
- kafka大小:82MBApache Kafka 3.0.0 (Scala 2.13 :kafka_2.13-3.0.0.tgz) 是一个开源分布式事件流平台,被数千家公司用于高性能数据管道、流分析、数据集成和关键任务应用程序。) 是一个开源分布式事件流平台,被数千家公司用于高性能数据管道、流分析、数据集成和关键任务应用程序。Apache Kafka 3.0.0 (Scala 2.13 :kafka_2.13-3.0.0.tgz) 是一个开源分布式事件流平台,被数千家公司用于高性能数据管道、流分析、数据集成和关键任务应用程序。) 是一个开源分布式事件流平台,被数千家公司用于高性能数据管道、流分析、数据集成和关键任务应用程序。0 154浏览¥ 9.90