阿里云文档 2024-05-30

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

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

问答 2024-05-14 来自:开发者社区

Flink1.12写kafka报错,Caused by: org.apache.kafka.comm

Flink1.12写kafka报错,Caused by: org.apache.kafka.common.errors.TimeoutException: Topic tag_change_stream not present in metadata after 60000 ms.

阿里云文档 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-07-17 来自:开发者社区

DataWorks中kafka同步任务,org.apache.kafka.clients.cons?

DataWorks中kafka同步任务,org.apache.kafka.clients.consumer.NoOffsetForPartitionException: Undefined offset with no reset policy for partitions?

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

「Kafka技术」Apache Kafka中的事务

在之前的一篇博客文章中,我们介绍了Apache Kafka®的一次语义。这篇文章介绍了各种消息传递语义,介绍了幂等生成器、事务和Kafka流的一次处理语义。现在,我们将继续上一节的内容,深入探讨Apache Kafka中的事务。该文档的目标是让读者熟悉有效使用Apache Kafka中的事务API所需的主要概念。我们将讨论设计事务API的主要用例、Kafka的事务语义、用于Java客户端的事务A....

「Kafka技术」Apache Kafka中的事务
阿里云文档 2023-05-25

如何监控开源ApacheKafka

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

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

「首席看Kafka」Apache Kafka中的事务

在之前的一篇博客文章中,我们介绍了Apache Kafka®的一次语义。这篇文章介绍了各种消息传递语义,介绍了幂等生成器、事务和Kafka流的一次处理语义。现在,我们将继续上一节的内容,深入探讨Apache Kafka中的事务。该文档的目标是让读者熟悉有效使用Apache Kafka中的事务API所需的主要概念。我们将讨论设计事务API的主要用例、Kafka的事务语义、用于Java客户端的事务A....

「首席看Kafka」Apache Kafka中的事务
文章 2023-05-18 来自:开发者社区

[Kafka ]全面介绍Apache Kafka™

介绍Kafka是一个现在听到很多的话......许多领先的数字公司似乎也在使用它。但究竟是什么呢?Kafka最初于2011年在LinkedIn开发,自那时起经历了很多改进。如今它是一个完整的平台,允许您冗余地存储荒谬的数据量,拥有一个具有巨大吞吐量(数百万/秒)的消息总线,并对同时通过它的数据使用实时流处理。Kafka是一个分布式,可水平扩展,容错的提交日志。那是一些奇特的话,让我们一个接一个地....

[Kafka ]全面介绍Apache Kafka™
问答 2022-08-24 来自:开发者社区

发送到kafka提示这个错误 org.apache.kafka.common.KafkaExcept

发送到kafka提示这个错误 org.apache.kafka.common.KafkaException: Could not add partitions to transaction due to errors: {t-bi-db-etl-flink-cdc-data-assembly-0=CORRUPT_MESSAGE}这个错误怎么在程序里修复?

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

产品推荐

Apache Spark 中国技术社区

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

+关注
相关镜像