Kafka常用命令 Kafka

kafka启动:bin/kafka-server-start.sh -daemon config/server.properties kafka停止:bin/kafka-server-stop.sh 选项说明: --topic topic名称 --replication-factor 副本数 --partitions 分区数 --zookeeper 本机ip...
晨曦 发布于 

Zookeeper+Kafka集群部署 Kafka

1.下载zookeeper和kafka: zk下载地址:http://archive.apache.org/dist/zookeeper/ kafka下载地址:https://kafka.apache.org/downloads.html 本次搭建下载的zk和kafka版本是(zookeeper-3.4.14.tar.gz/kafka_2.11-0.11.0...
晨曦 发布于 

Kafka事务 Kafka

Kafka从0.11版本开始引入了事务支持。事务可以保证Kafka在Exactly Once语义的基础上,生产和消费可以跨分区和会话,要么全部成功,要么全部失败 。 Producer事务: 为了实现跨分区跨会话的事务,需要引入一个全局唯一的Transaction ID,并将Producer获得的PID和Transaction ID绑定。这样当Producer...
晨曦 发布于 

计算机组成与体系结构 Java基础

1.计算机硬件组成: 1.1.控制器: 程序计数器、指令寄存器IR、指令译码器ID、时序部件 控制器:分析和执行指令程序计数器PC:存储下一条要执行指令的地址指令寄存器IR:存储即将执行的指令指令译码器:对指令中的操作码字段进行分析解释时序部件:提供时序控制信号 1.2.运算器: 算术逻辑单元ALU、累加寄存器AC、数据缓冲寄存器DR、...
晨曦 发布于 

EFK(日志收集)统一管理 Elasticsearch

(E)Elasticsearch: (F)Filebeat: (K)Kibana:
晨曦 发布于 

ReentrantLock、AQS底层实现原理 并发编程

ReentrantLock介绍: 在单线程情况下交替执行与队列无关,因为使用JDK级别解决同步问题。 可重入锁: 线程已经获取某个共享资源的锁之后,释放锁之前,当前线程还可以再次对于这个共享资源获取锁(锁计数器[state+1])。 在jdk1.6之前->ReentrantLock和Synchronized的区别: Reentra...
晨曦 发布于 

Elasticsearch DSL语言查询与过滤 Elasticsearch

Elasticsearch中查询有两种方式: 1.简易版查询 2.JSON完整的请求体,称为结构化查询(DSL) DSL是发送POST请求传JSON格式数据进行查询,灵活性高。 Term与Match查询区别: Term:不会对该字段进行分词查询,采用精确匹配查询方式 Match:根据该字段的分词器进行分词查询,采用模糊查询方式 创建测试数据 PUT 索引/类...
晨曦 发布于 

Kafka-Eagle搭建可视化工具 Kafka

集群三台机器 在Hosts文件中建立域名和IP的映射配置(方便解析): vim /etc/hosts 192.168.0.1                     master 192.168.0.2                     slave1 192.168.0.3                     slave2 配置环境变量:vim /...
晨曦 发布于 

Centos安装mysql 8.0 Mysql

注意:本次安装目录为/opt/module/ 下载mysql安装包 [root@chenxi module]# wget https://downloads.mysql.com/archives/get/p/23/file/mysql-8.0.18-linux-glibc2.12-x86_64.tar.xz 解压安装包 [root@chenxi module...
晨曦 发布于 

JVM栈帧内部结构-动态链接 Jvm

动态链接(或运行时常量池的方法引用):         每一个栈帧内部都包含一个指向运行时常量池中该栈帧所属方法的引用,包含这个引用的目的就是为了支持当前方法的代码能够实现动态链接(Dynamic Linking)。比如:invokedynamic指令         在Java源文件被编译到字节码文件时,所有的变量和方法引用都作为符号引用(Symbilic...
晨曦 发布于