阿里云文档 2024-05-30

配置事件流的提供方为自建Apache Kafka

本文介绍如何在事件总线EventBridge控制台添加自建Apache Kafka作为事件流中的事件提供方。

阿里云文档 2024-03-22

Apache Kafka Connect远程代码执行漏洞

2023年02月08日,Apache发布了一则安全公告,修复了Apache Kafka中存在的一个反序列化漏洞,漏洞编号为CVE-2023-25194。在攻击者可以控制Apache Kafka Connect客户端的情况下,通过SASL JAAS配置和基于SASL的安全协议,在其上创建或修改连接器,从而触发JNDI代码执行漏洞。

阿里云文档 2024-03-18

使用Confluent Replicator复制数据

Kafka MirrorMaker是一款用于在两个Apache Kafka集群之间复制数据的独立工具。它将Kafka消费者和生产者连接在一起。从源集群的Topic读取数据,并写入目标集群的同名Topic。相比于Kafka MirrorMaker,Confluent Replicator是一个更完整的解决方案,它能复制Topic的配置和数据,还能与Kafka Connect和Control Cent...

文章 2023-05-29 来自:开发者社区

Apache Kafka-通过API获取主题所有分区的积压消息数量

实现package com.artisan.bootkafka.controller; import org.apache.kafka.clients.consumer.KafkaConsumer; import org.apache.kafka.common.PartitionInfo; import org.apache.kafka.common.TopicPartition; import....

Apache Kafka-通过API获取主题所有分区的积压消息数量
阿里云文档 2023-05-25

如何监控开源ApacheKafka

本文为您介绍监控开源Apache Kafka的解决方案。

文章 2022-05-09 来自:开发者社区

Apache Kafka:主题分区,副本和ISR

阅读时间: 6 分钟在较早的博客中,我们介绍了Kafka的基本术语,并进一步深入了Zookeeper。现在,让我们详细讨论主题分区和副本。主题分区主题(Topic)或称消息队列,是您在Kafka中数据的存放位置。主题的数据进一步分为多个分区(Partition)。每个分区都是有序的,不可变的记录序列,这些记录连续地附加到结构化的提交日志中。当发布带有密钥的消息(带密钥的消息)时,Kafka根据密....

Apache Kafka:主题分区,副本和ISR
问答 2018-12-11 来自:开发者社区

Apache Flink - kafka生产者将消息传递给kafka主题,但在不同的分区上

现在我的flink代码正在处理一个文件并使用1分区将kafka主题上的数据下沉。 现在我有一个带有2分区的主题,我希望flink代码使用DefaultPartitioner在这两个分区上接收数据。 你能帮帮我吗? 这是我当前代码的代码片段: DataStream speStream = inputStream..map(new MapFunction(){....}Properties prop....

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

Apache Spark 中国技术社区

阿里巴巴开源大数据技术团队成立 Apache Spark 中国技术社区,定期推送精彩案例,问答区数个 Spark 技术同学每日在线答疑,只为营造 Spark 技术交流氛围,欢迎加入!

+关注
相关镜像