码迷,mamicode.com
首页 >  
搜索关键字:kafka offset monitor    ( 8784个结果
kafka基础操作
1.官网 http://kafka.apache.org/ 2.介绍 一个分布式的流平台 3.特点 具有高吞吐量,高性能,实时,高可靠 二:安装 1.全部上传 2.全部解压 3.安装jdk 4.zookeeper的安装 进入zookeeper的目录下的conf中 将zoo_sample.cfg拷贝一 ...
分类:其他好文   时间:2020-07-27 09:19:58    阅读次数:65
verilog之monitor
verilog之monitor 1、函数作用 monitor用于追踪变量的变化情况,这在实际使用中还是非常实用的。电路中的某个信号的变化可以通过monitor检测,不需要使用波形图去仔细查找。也便于准确描述某个信号的变化。 2、基本用法 module monitor; reg a_monitor; ...
分类:其他好文   时间:2020-07-26 01:45:00    阅读次数:101
单页面导航定位跳转插件
引入``` <script src="js/jqurey.singlePageNav.min.js"></script> <script> $(function(){ //导航跳转效果插件 $('.nav').singlePageNav({ offset:70; //向上偏移量 }); //小屏幕导 ...
分类:其他好文   时间:2020-07-26 01:24:24    阅读次数:96
Kafka 0.10.1版本源码 Idea编译
Kafka 0.10.1版本源码 Idea编译 1.环境准备 Jdk 1.8 Scala 2.11.12:下载scala-2.11.12.msi并配置环境变量 Gradle 5.6.4: 下载Gradle-5.6.4并配置环境变量 2.配置文件修改 -gradle.properties文件中 sca ...
分类:其他好文   时间:2020-07-26 00:28:42    阅读次数:75
解决 Flink 1.11.0 sql 不能指定 jobName 的问题
月初的时候,Flink 终于发布 1.11.0 版本, CDC 的功能还是比较期待的(虽然比预期差很多) 当然是升级一波了 最新的代码已经上传到 GitHub : https://github.com/springMoon/sqlSubmit 跑 sqlSubmit 的代码,随便来个 kafka t ...
分类:数据库   时间:2020-07-26 00:01:52    阅读次数:179
MongoDB权限控制(6)
权限概述 在mongodb里面的用户是属于数据库的,每个数据库有自己的管理员,管理员登录后,只能操作所属的数据库。 注意:一般在admin数据库中创建的用户授予超级管理员权限,登录后可以操作任何的数据库。 创建超级管理员 注意:在开启权限管理控制时,一定先要创建一个超级管理员授予超级管理权限。 (1 ...
分类:数据库   时间:2020-07-25 23:49:05    阅读次数:74
Hadoop基础(五十):压缩和存储(二)
4 开启 Reduce 输出阶段压缩 当 Hive 将 输 出 写 入 到 表 中 时 , 输 出 内 容 同 样 可 以 进 行 压 缩 。 属 性hive.exec.compress.output 控制着这个功能。用户可能需要保持默认设置文件中的默认值 false, 这样默认的输出就是非压缩的纯 ...
分类:其他好文   时间:2020-07-24 21:30:31    阅读次数:69
kafka配置双监听
kafka配置双监听 由于公司需要在其他城市开通业务所以另外开了一个数据库但是kafka消费想直接使用旧的项目,以免多部署一个项目占用服务器内存空间。 首先先在配置文件中配置2个kafka的ip端口等信息 spring.kafka.xx.bootstrap-servers=xxx.xxx.x.x:x ...
分类:其他好文   时间:2020-07-24 10:03:45    阅读次数:71
Java中的锁原理、锁优化、CAS、AQS详解
1、为什么要用锁? 锁-是为了解决并发操作引起的脏读、数据不一致的问题。 2、锁实现的基本原理 2.1、volatile Java编程语言允许线程访问共享变量, 为了确保共享变量能被准确和一致地更新,线程应该确保通过排他锁单独获得这个变量。Java语言提供了volatile,在某些情况下比锁要更加方 ...
分类:编程语言   时间:2020-07-24 09:33:02    阅读次数:63
flume从Kafka消费数据到HDFS
#source的名字 agent.sources = kafkaSource # channels的名字,建议按照type来命名 agent.channels = memoryChannel # sink的名字,建议按照目标来命名 agent.sinks = hdfsSink # 指定source使 ...
分类:Web程序   时间:2020-07-23 22:28:11    阅读次数:105
8784条   上一页 1 ... 33 34 35 36 37 ... 879 下一页
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!