redis Redis分布式锁之redisson
Redis分布式锁之redisson 常用的redis解决方案： redisson官网，官方讲解可以点击这里 redisson实现分布式锁原理： 线程首先会尝试获取锁，如果获取锁成功，会执行加锁操作并执行业务代...
kafka Kafka的消息是如何被消费的?
Kafka的消息消费是以消费的group为单位; 同属一个group中的多个consumer分别消费topic的不同partition; 同组内consumer的变化, partition变化, coordinator的变化都会引发balance; 消费的...
kafka kafka 消费者offset记录位置和方式
我们大家都知道，kafka消费者在会保存其消费的进度，也就是offset，存储的位置根据选用的kafka api不同而不同。 首先来说说消费者如果是根据javaapi来消费，也就是【kafka.javaapi.consumer....
spring Spring Kafka中关于Kafka的配置参数
1 #################consumer的配置参数（开始）################# 2 #如果'enable.auto.commit'为true，则消费者偏移自动提交给Kafka的频率（以毫秒为单位），默认值为5000。 3 spring....
spring SpringBoot集成kafka全面实战
本文是SpringBoot+Kafka的实战讲解，如果对kafka的架构原理还不了解的读者，建议先看一下《大白话kafka架构原理》、《秒懂kafka HA（高可用）》两篇文章。 一、生产者实践 普通生产者 带回调...
kafka kafka 00000000000000000000.timeindex: 另一个程序正在使用此文件，进程无法访问。
解决方式：手动删除\kafka-logs里的日志文件重启kafka 2、出现两个Consumer同时消费同一个topic下面的同一个group，只有一个能够读取到数据： 原因： 相同的group下面的消费者访问的东西不会...
kafka kafka在windows下安装单机版
1、环境准备jdk8 kafka_2.12-2.1.1（已包含了zookeeper，无需自行下载zk也无需安装）2、下载kafka，本文采用的是：Scala 2.12 - kafka_2.12-2.1.1.tgz (asc, sha512)...
kafka kafka之常用命令
#1.1 kafka启动命令nohup bin/kafka-server-start.sh config/server.properties .2 kafka停止命令bin/kafka-server-stop.sh #1.3. kafka重启systemctl restart kafka #2.1 ka...
kafka Kafka 配置外网访问
说明 Kafka 有的时候会跨机房接收消息，本地开发机也需要向远程服务器发一些消息，默认是不支持外连的，所以需要配置一下远程访问。 Kafka 服务器 host 修改 查看 hostname，查看内网 IP ...
kafka Kafka-＞一个好用的IntelliJ IDEA插件: kafkalytic
Kafka->一个好用的IntelliJ IDEA插件: kafkalytic安装kafkalytic如何连接kafka集群kafkalytic简单的使用安装点击File -> Setting 1.点击Plugins2.在搜索框输入Kafka3.安装Kafkalytic(...