linq
-
分布式 – 消息队列Kafka：Kafka生产者发送消息的方式
文章目录 1. Kafka 生产者 2. kafaka 命令行操作 3. kafka 生产者发送消息流程 4. Kafka 生产者的创建 5. Kafka 生产者发送消息 1. 发…
-
Kafka入门，手动提交offset，同步提交，异步提交，指定 Offset 消费（二十三）
手动提交offset 虽然offset十分遍历，但是由于其是基于时间提交的，开发人员难以把握offset提交的实际。因此Kafka还提供了手动提交offset的API 手动提交of…
-
FlinkSQL处理Canal-JSON数据
背景信息 Canal是一个CDC（ChangeLog Data Capture，变更日志数据捕获）工具，可以实时地将MySQL变更传输到其他系统。Canal为变更日志提供了统一的数…
-
ubuntu安装kafka
一、前提，先去安装java环境 二、安装kafka wget http://www.apache.org/dyn/closer.cgi?path=/kafka/2.8.0/kafk…
-
消息中间件：Kafka
(1)Zookeeper安装 https://downloads.apache.org/zookeeper/ （1）更新系统的包管理器 sudo yum update （2）安装J…
-
自定义kafka客户端消费topic
文章目录 自定义kafka客户端消费topic 结论 1 背景 2 spring集成2.1.8.RELEASE版本不支持autoStartup属性 3 自定义kafka客户端消费t…
-
【kafka】Java客户端代码demo：自动异步提交、手动同步提交及提交颗粒度、动态负载均衡
一，代码及配置项介绍 kafka版本为3.6，部署在3台linux上。 maven依赖如下： org.apache.kafka kafka_2.13 3.6.0 生产者、消费者和t…
-
Kafka实战：消费指定时间范围内的Kafka Topic数据
Kafka实战：消费指定时间范围内的Kafka Topic数据 在大数据领域，Kafka是一个广泛使用的分布式流数据平台。它提供了高吞吐量、可扩展性和容错性，使得实时数据流处理变得…
-
SparkStreaming与Kafka整合
1.3 SparkStreaming与Kafka整合 1.3.1 整合简述 kafka是做消息的缓存，数据和业务隔离操作的消息队列，而sparkstreaming是一款准实时流式计…
-
Kafka事务是怎么实现的？Kafka事务消息原理详解（文末送书）
目录 一、Kafka事务性消息 1.1 介绍Kafka事务性消息 1.2 事务性消息的应用场景 1.3 Kafka事务性消息的优势 二、Kafka事务性消息的使用 2.1 配置Ka…
-
Kafka消费流程
Kafka消费流程 消息是如何被消费者消费掉的。其中最核心的有以下内容。 1、多线程安全问题 2、群组协调 3、分区再均衡 1.多线程安全问题 当多个线程访问某个类时，这个类始终都…
-
Kafka中的Topic
在Kafka中，Topic是消息的逻辑容器，用于组织和分类消息。本文将深入探讨Kafka Topic的各个方面，包括创建、配置、生产者和消费者，以及一些实际应用中的示例代码。 1….
-
Kafka快速入门
Kafka快速入门 1、MQ简介 生产者向队列发送消息，消费者从队列消费消息，先进先出属于队列类型。常用的消息中间件有RabbitMQ、RocketMQ、kafka等，使用消息中间…
-
【中间件】消息中间件之Kafka
一、概念介绍 Apache Kafka是一个分布式流处理平台，用于构建实时数据管道和流应用。它可以处理网站、应用或其他来源产生的大量数据流，并能实时地将这些数据流传输到另一个系统或…
-
Kafka 的消息格式：了解消息结构与序列化
Kafka 作为一款高性能的消息中间件系统，其消息格式对于消息的生产、传输和消费起着至关重要的作用。本篇博客将深入讨论 Kafka 的消息格式，包括消息的结构、序列化与反序列化，以…
