大家好，这是一个为了梦想而保持学习的博客。这个专题会记录我对于KAFKA的学习和实战经验，希望对大家有所帮助，目录形式依旧为问答的方式，相当于是模拟面试。 一、写在前面 本来是打算写到消费者模块的时候再详细看一下和写一下rebalance过程，但是前阵子遇到的rebalance的问题比较多，发现自己 ...
分类：
其他好文 时间：
2021-05-24 00:09:26
阅读次数：
0
一、kafka Kafka是一个分布式的消息系统。 二、解决问题 消息系统通常被应用于异步处理、应用解耦、流量削峰、消息通信等场景。 异步处理 image-20210315230129937 生产者将消息写入消息队列中，消费者异步拉取消息队列消息，从而提升消息处理能力。 应用解耦 image-202 ...
分类：
其他好文 时间：
2021-05-23 23:45:42
阅读次数：
0
/* Optional 容器类常用方法 Optional.of(T t) 创建一个Optional实例 Optional.empty() 创建一个空的Optional实例 Optional.ofNullable(T t) 若t不为null,则创建Optional实例，否则创建空实例 isPresen ...
分类：
编程语言 时间：
2021-05-04 16:30:31
阅读次数：
0
Prefix and Suffix Search (H) 题目 Design a special dictionary which has some words and allows you to search the words in it by a prefix and a suffix. Im ...
分类：
其他好文 时间：
2021-05-03 12:54:25
阅读次数：
0
做别名扫描添加的硬盘 [root@localhost ks]# alias scandisk="echo '- - -' > /sys/class/scsi_host/host0/scan;echo '- - -' > /sys/class/scsi_host/host1/scan;echo '- ...
分类：
其他好文 时间：
2021-05-03 12:39:12
阅读次数：
0
Mysql配置读写数据库 ERROR 1227 (42000): Access denied; you need (at least one of) the SUPER privilege(s) for this operation 原因之前mysql的vi /etc/my.cnf 修改配置没有重启 ...
分类：
其他好文 时间：
2021-04-30 12:42:22
阅读次数：
0
build.gradle添加implementation libs.slf4jApi ...
分类：
其他好文 时间：
2021-04-30 12:19:59
阅读次数：
0
1、连接demo是采用的这篇博客中的内容： https://blog.csdn.net/weixin_39098944/article/details/108067005 主要代码如下： （1）添加依赖 1 <dependency> 2 <groupId>org.apache.kafka</grou ...
分类：
编程语言 时间：
2021-04-30 12:13:39
阅读次数：
0
VMware虚拟机 Linux系统 Ubuntu 16.04 硬盘/磁盘扩容效果查看硬盘大小及使用情况 终端：df -h 没有扩容前： 成功扩容后： 主要流程扩展硬盘大小到100G将未分配的60G分配到主分区更新UUID值超详细图文详解扩容步骤查看磁盘的情况后，关闭客户机，可以看到现在硬盘大小为 ： ...
分类：
系统相关 时间：
2021-04-29 11:39:46
阅读次数：
0
1. 搭建测试环境安装 1.1 下载并启动docker-compose容器 # 该 Docker Compose 中包含的容器有： # DataGen：数据生成器。容器启动后会自动开始生成用户行为数据，并发送到 Kafka 集群中。默认每秒生成 1000 条数据，持续生成约 3 小时。也可以更改 d ...
分类：
数据库 时间：
2021-04-28 11:43:18
阅读次数：
0
