Centos Firewalld防火墙设置 Linux相关

Centos7及以上默认安装了firewalld,如果没有安装的话,可以使用 yum install firewalld firewalld-config进行安装。 1.启动防火墙 systemctl start firewalld 2.禁用防火墙 systemctl stop firewalld 3.设置开机启动 systemctl enable fire...
晨曦 发布于 

Zookeeper搭建集群问题 Linux相关

错误日志:ZooKeeper JMX enabled by default Using config: /opt/module/zookeeper-3.4.14/bin/../conf/zoo.cfg Error contacting service. It is probably not running. 解决方案: 1.注意myid文件内容是否对应zk集...
晨曦 发布于 

Kafka进阶之幂等性以及分区分配策略 Kafka

Exactly Once语义: 将服务器的ACK级别设置为-1,可以保证Producer到Server之间不会丢失数据,即At Least Once 语义。相对的,将服务器ACK级别设置为0,可以保证生产者每条消息只会被发送一次,即At Most Once语义。 At Least Once可以保证数据不丢失,但是不能保证数据不重复;相对的, At Least...
晨曦 发布于 

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 索引/类...
晨曦 发布于