在消息RabbitMQ时,我们关心的一个问题是手动ack还是自动ack,如果是自动ack就怕出现丢消息的情况 Flink以RabbitMQ作为Source,是怎么保证消息唯一性的呢,是怎么保证ack的. 首先引入依赖包 <dependency> <groupId>org.apache.flink</ ...
分类：
其他好文 时间：
2021-06-11 19:15:45
阅读次数：
0
业务使用maxwell监听数据库的binlog日志，然后发送到kafka，经过这些日志进行业务逻辑的处理。 问题：线上的这段业务没有进行执行。 猜测1、由于前段时间进行了数据库表的字段转移，把两个字段从上层表order下放到了下层表advert，以为是这段代码进行改写的时候没能覆盖逻辑。 看了代码之 ...
分类：
其他好文 时间：
2021-06-11 18:59:01
阅读次数：
0
前言 由于业务量的增大，用户量增大、并发量增高，数据量增多，导致页面查询速度降低，只用传统的关系型数据库已经无法支撑系统的高并发，高可用的场景了。 关系型数据库的缺点： 1.性能瓶颈：磁盘IO性能低下 1.扩展瓶颈：数据关系复杂，扩展性差，不便于大规模的集群 解决思路 1.降低磁盘IO次数 2.去除 ...
分类：
其他好文 时间：
2021-06-11 18:42:27
阅读次数：
0
对于一些活动相关的业务场景，如果设置了到时间开启，可以通过自己实现延时队列的方式来完成类似业务。如添加完活动用活动开启时间减去当前时间，去创建延时任务，再将其添加到延时队列中，以此来完成到时间活动自动开启关闭的功能，当然这种方式只适用于单体架构，如果是集群或分布式，需要自行加分布式锁或利用redis ...
分类：
编程语言 时间：
2021-06-11 18:26:12
阅读次数：
0
其实很早就是用kafka了，但是一直都用的非常简单，最近写一个小功能的时候又要用到kafka，于是就花点时间好好看了一下网上关于kafka的一些文档和博客，发现了一个很不错的博客，做个记录和分享。 原文链接： https://www.cnblogs.com/rexcheny/articles/946 ...
分类：
编程语言 时间：
2021-06-11 18:14:50
阅读次数：
0
前言 Apache Kafka的受欢迎程度很高，Kafka拥有充足的就业机会和职业前景。此外，在这个时代拥有kafka知识是一条快速增长的道路 而且无论是作为面试官，还是应聘者，我都接触过很多Kafka面试题。而在最近面试了很多候选人，发现写了熟悉Kafka，但是对于Kafka相关的知识却是只知道大 ...
分类：
编程语言 时间：
2021-06-11 18:11:03
阅读次数：
0
1. Service Service对象的IP地址也称为Cluster IP，是一种虚拟IP地址，能被同一集群的Pod资源所访问。Service端口用于接收客户端请求并将其转发至其后端的Pod中应用的相应端口之上。这种代理称为“端口代理”或四层代理，它工作于TCP/IP协议栈的传输层。 Servic ...
分类：
其他好文 时间：
2021-06-11 18:10:35
阅读次数：
0
一、文件存储 kafka 使用日志文件的方式来保存生产者和发送者的消息，每条消息都有一个 offset 值来表示它在分区中的偏移量。Kafka 中存储的一般都是海量的消息数据，为了避免日志文件过大，一个分片 并不是直接对应在一个磁盘上的日志文件，而是对应磁盘上的一个目录，这个目录的命名规则是<top ...
分类：
其他好文 时间：
2021-06-11 17:32:01
阅读次数：
0
准备 事先准备好k8s集群,打包你的项目并上传到docker仓库 yaml文件 k8s的yaml文件可以自己手动写（不推荐），也可以通过kubectl create生成，这里不多说了，网上相关的文章多的是。。。下面是我的yaml文件。 test-deployment.yaml apiVersion: ...
分类：
编程语言 时间：
2021-06-10 18:39:43
阅读次数：
0
k8s证书浅析 来源：https://zhuanlan.zhihu.com/p/123858320 建K8S集群 kubeadm 会生成的很多证书 [root@k8s-master01 ~]# cd /etc/kubernetes/pki [root@k8s-master01 pki]# tree ...
分类：
其他好文 时间：
2021-06-10 18:23:04
阅读次数：
0
