kafka

戳上方蓝字“Java知音”关注我 前言 经过前面对Spring AOP、事务的总结，我们已经对它们有了一个比较感性的认知了。今天，我继续安利一个独门绝技：Spring 事务的钩子函…

现在，刷视频已经成为我们生活中的一部分，而且很容易一看就停不下来。你有没有好奇过，它是如何在海量的视频里，找到让你感兴趣的视频？又是如何让你可以通过关键字，搜索到与之相关的视频内容…

原文地址：https://blog.pickme.lk/how-to-get-profiling-right-with-go-813ff89d4757 Go 是谷歌开发的一种编程语…

为什么有 HTTPS？因为 HTTP 不安全！ 现在的互联网已经不再是 “田园时代”，“黑暗森林” 已经到来。上网的记录会被轻易截获，网站是否真实也无法验证，黑客可以伪装成银行网站…

概述 Kafka是一种高吞吐量的分布式发布订阅消息系统，它可以处理消费者在网站中的所有动作流数据。其核心组件包含Producer、Broker、Consumer，以及依赖的Zook…

前章内容聊到了Kafka的Kraft集群的配置及使用。本篇再来说说kafka的安全认证方面的配置。 Kafka提供了多种方式来进行安全认证，包括身份认证、授权和加密传输。一些常用的…

点击上方蓝字关注我！ 背景 有这样一个场景，有两台服务器A，B。你在A服务器上写了一个程序，这个程序功能是将服务器A的数据拷贝到服务器B上。这个功能会经历下面几步。 “ 1.数据从…

点击上方蓝字关注我！ WebSocket技术可以让服务端主动将信息推送给客户端，不必像Http协议那样客户端想要获取服务端数据，必须要向服务端发起一个请求。 WebSocket是全…

背景 Debezium Server Databend 是一个基于 Debezium Engine 自研的轻量级 CDC 项目，用于实时捕获数据库更改并将其作为事件流传递最终将数据…

1、背景 在我们的项目中有这么一个场景，需要消费kafka中的消息，并生成对应的工单数据。早些时候程序运行的好好的，但是有一天，我们升级了容器的配置，结果导致部分消息无法消费。而消…

Uber 是一个全球品牌，在全球 10,000 多个城市运营。该公司运营规模庞大，每月为超过 1.37 亿用户提供服务，每天为 2500 万次出行提供服务。数据驱动——乘客、司机和…

前言 1.缓存未命中： 2.缓存击穿： 3.命令过于频繁： 4.连接数过多： 5.数据持久化导致的阻塞： 6.主从存在频繁全量同步： 7.value值过大： 8.Redis慢查询：…

1. 请解释并发编程的概念，以及它与多线程、多进程的区别。 答：并发编程是指在同一时间内执行多个任务的编程方法。它可以通过多线程、多进程或异步编程实现。与多线程相比，并发编程更关注…

原文：《Manning.100.Go.Mistakes.and.How.to.Avoid.Them》61-67 从本文中将会学到 防止 goroutine 的常见错误和channe…

一款真正的云原生 Kafka 解决方案。该项目是基于云原生重新设计的新一代 Kafka 发行版。在保持和 Apache Kafka 100%兼容前提下，AutoMQ 可以为用户提供…

应用程序是如何在Kubernetes上运行的？ 文章译自 HOW DO APPLICATIONS RUN ON KUBERNETES?[1]，作者 Janakiram MSV。 以…