logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

nc+flink模拟消费kafka

k<通信端口>强制 nc 待命链接.当客户端从服务端断开连接后,过一段时间服务端也会停止监听。但通过选项 -k 我们可以强制服务器保持连接并继续监听端口。-l 开启 监听模式,用于指定nc将处于监听模式。通常 这样代表着为一个 服务等待客户端来链接指定的端口。Flink程序订阅对应端口的socket流,模拟消费kafka数据。-p<通信端口> 设置本地主机使用的通信端口。中,命令nc -lk 和n

文章图片
#flink#kafka
Idea集成scala

scala版本和jdk版本有关系的,scala官网对此作了明确的要求。推荐使用JDK8和11。JDK 兼容性。

#scala#intellij-idea#开发语言
高并发限流之令牌桶

限流可以认为服务降级的一种,限流就是限制系统的输入和输出流量已达到保护系统的目的。一般来说系统的吞吐量是可以被测算的,为了保证系统的稳定运行,一旦达到的需要限制的阈值,就需要限制流量并采取一些措施以完成限制流量的目的。比如:延迟处理,拒绝处理,或者部分拒绝处理等等。简单点来说就是:一定时间内把请求量限制在一定范围内,保证系统不被冲垮,同时尽可能提升系统的吞吐量。

文章图片
#java#算法#数据库
虚拟机的集群信息记录@20220417

虚拟机的集群信息记录@20220417

#kafka#zookeeper#linux
到底了