java云消息队列 Kafka 版的相关内容

阿里云文档 2024-12-02

Java客户端和Sarama Go客户端的兼容性说明

本文介绍了Java客户端和Sarama Go在数据层面和管控层面的兼容性详情。

文章 2024-11-10 来自：开发者社区

java nio，netty，kafka 中经常提到“零拷贝”到底是什么？

零拷贝技术 Zero-Copy 是指计算机执行操作时，可以直接从源（如文件或网络套接字）将数据传输到目标缓冲区，而不需要 CPU 先将数据从某处内存复制到另一个特定区域，从而减少上下文切换以及 CPU 的拷贝时间。 1 I/O 中断原理在 DMA 技术出现之前，应用程序与磁盘之间的 I/O 操作都是通过 CPU 的中断完成的。用户进程向 CPU 发起 read 系统调用读取数据，由用...

文章 2024-10-12 来自：开发者社区

Flink-10 Flink Java 3分钟上手 Docker容器化部署 JobManager TaskManager Kafka Redis Dockerfile docker-compose

代码仓库会同步代码到 GitHub https://github.com/turbo-duck/flink-demo 本节内容在学习和测试阶段，需要快速启动一套Flink供我们学习测试。使用常规的安装的方式太费劲了，利用Docker可以快速启动一套完整的系统，方便我...

文章 2024-10-12 来自：开发者社区

Flink-07 Flink Java 3分钟上手滚动窗口事件驱动 Kafka TumblingWindow GlobalWindow CountWindow

代码仓库会同步代码到 GitHub https://github.com/turbo-duck/flink-demo 上节进度上节完成了滚动窗口时间驱动 TumblingWindow TimeWindowFunction。本节和上节内容相似，但是上节是...

文章 2024-10-12 来自：开发者社区

Flink-06 Flink Java 3分钟上手滚动窗口时间驱动 Kafka TumblingWindow TimeWindowFunction TumblingProcessing

代码仓库会同步代码到 GitHub https://github.com/turbo-duck/flink-demo 上节进度上一节，已经实现了 Flink + Kafka + Redis 的相关配置和代码。 Kakfa Redis In Docker ...

文章 2024-10-12 来自：开发者社区

Flink-05 Flink Java 3分钟上手 Redis FlinkJedisPoolConfig 从Kafka写入Redis FlinkKafkaConsumer消费结果写入Redis

代码仓库会同步代码到 GitHub https://github.com/turbo-duck/flink-demo 内容介绍上节我们已经实现了，对Kafka数据的消费和计算，最终把结果输出到了控制台上。如下图： Kafka In Docker ...

文章 2024-10-12 来自：开发者社区

Flink-04 Flink Java 3分钟上手 FlinkKafkaConsumer消费Kafka数据进行计算SingleOutputStreamOperatorDataStreamSource

代码仓库会同步代码到 GitHub https://github.com/turbo-duck/flink-demo pom.xml 修改pom.xml，需要加入 kafka相关的包，和适配器。 ...

问答 2024-08-15 来自：开发者社区

给一个使用Java实现的Kafka消费者示例代码？

文章 2024-07-28 来自：开发者社区

Java 客户端访问kafka

本文为博主原创，未经允许不得转载：　　1. 引入maven依赖 <dependency> <groupId>org.apache.kafka</groupId> <artifactId&...

文章 2024-07-05 来自：开发者社区

如何在Java中使用Kafka

如何在Java中使用Kafka Kafka是一个分布式流处理平台，广泛用于实时数据流的处理和传输。本文将详细介绍如何在Java中使用Kafka，并通过示例代码展示如何实现生产者和消费者。 1. 准备工作在开始编写代码之前，需要完成以下准备工作：安装Kafka并启动Kafka服务器。添加Kafka的Java客户端依赖。 ...