文章 2024-08-25 来自:开发者社区

【Azure 事件中心】使用Kafka的性能测试工具(kafka-producer-perf-test)测试生产者发送消息到Azure Event Hub的性能

问题描述 Azure Event Hub支持 kafka,所以为了测试消息生产者所在环境与Azure Event  Hub之间发送消息的性能如何,特别使用 kafka 官方测试生产者,消费者的性能工具 : kafka-producer-perf-test.bat kafka-consumer-perf-test.bat (.bat...

【Azure 事件中心】使用Kafka的性能测试工具(kafka-producer-perf-test)测试生产者发送消息到Azure Event Hub的性能
文章 2024-08-24 来自:开发者社区

【Azure 事件中心】在Windows系统中使用 kafka-consumer-groups.bat 查看Event Hub中kafka的consumer groups信息

问题描述 使用 Apache Flink 连接支持 Apache Kafka的Azure Event Hub后,由于消费端的Consumer Group是动态创建,在门户页面和Service Bus Explorer工具中均无法查看,所以如何来查看 Kafka consumer group呢?可以参考以下内容:   使用前提 将 Apache Flink...

【Azure 事件中心】在Windows系统中使用 kafka-consumer-groups.bat 查看Event Hub中kafka的consumer groups信息
文章 2024-08-24 来自:开发者社区

【Azure 事件中心】在微软云中国区 (Mooncake) 上实验以Apache Kafka协议方式发送/接受Event Hubs消息 (Java版)

问题描述 事件中心提供 Kafka 终结点,现有的基于 Kafka 的应用程序可将该终结点用作运行你自己的 Kafka 群集的替代方案。 事件中心可与许多现有 Kafka 应用程序配合使用。在Azure官方提供的Demo中,都是针对Global Azure。以下内容通过实验来一步一步调试并在Azure中国区连接Event Hub成功。   操作步骤 ...

【Azure 事件中心】在微软云中国区 (Mooncake) 上实验以Apache Kafka协议方式发送/接受Event Hubs消息 (Java版)
文章 2024-05-19 来自:开发者社区

实时计算 Flink版操作报错合集之使用 Event Time Temporal Join 关联多个 HBase 后,Kafka 数据的某个字段变为 null 是什么原因导致的

问题一:flink1.16.0,sql-client客户端,报这个错,请问这个是什么问题啊? flink1.16.0,sql-client客户端,yarn-session下运行,报这个错,请问大佬这个是什么问题啊?怎么解决? ...

实时计算 Flink版操作报错合集之使用 Event Time Temporal Join 关联多个 HBase 后,Kafka 数据的某个字段变为 null 是什么原因导致的
文章 2024-05-19 来自:开发者社区

实时计算 Flink版操作报错合集之使用 Event Time Temporal Join 关联多个 HBase 后,Kafka 数据的某个字段变为 null 是什么原因导致的

问题一:请问一下Flink:我将docker镜像推到k8s上报错(如下图)。请问是什么原因呀? 请问一下Flink:我将docker镜像推到k8s上报错(如下图)。请问是什么原因呀? 参考回答: -...

实时计算 Flink版操作报错合集之使用 Event Time Temporal Join 关联多个 HBase 后,Kafka 数据的某个字段变为 null 是什么原因导致的
问答 2024-04-10 来自:开发者社区

函数计算fc3中配置了kafka触发器收不到event需要怎样排查问题?

函数计算fc3中配置了kafka触发器收不到event需要怎样排查问题?

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

【首席架构师看Event Hub】Kafka深挖 -第2部分:Kafka和Spring Cloud Stream

在这个博客系列的第1部分之后,Apache Kafka的Spring——第1部分:错误处理、消息转换和事务支持,在这里的第2部分中,我们将关注另一个增强开发者在Kafka上构建流应用程序时体验的项目:Spring Cloud Stream。我们将在这篇文章中讨论以下内容:Spring云流及其编程模型概述Apache Kafka®集成在Spring云流Spring Cloud Stream如何让K....

【首席架构师看Event Hub】Kafka深挖 -第2部分:Kafka和Spring Cloud Stream
文章 2023-05-23 来自:开发者社区

「首席看Event Hub」如何在您的Spring启动应用程序中使用Kafka

在体系结构规划期间选择正确的消息传递系统始终是一个挑战,但这是需要确定的最重要的考虑因素之一。作为一名开发人员,我每天都要编写需要服务大量用户并实时处理大量数据的应用程序。通常,我将Java与Spring框架(Spring Boot、Spring数据、Spring云、Spring缓存等)一起使用。Spring Boot是一个框架,它允许我比以前更快更轻松地完成开发过程。它已在我的组织中发挥了关键....

「首席看Event Hub」如何在您的Spring启动应用程序中使用Kafka
文章 2023-05-23 来自:开发者社区

「首席架构师看Event Hub」Kafka的Spring 深入挖掘 -第1部分

接下来是《如何在您的Spring启动应用程序中使用Apache Kafka》https://www.confluent.io/blog/apache-kafka-spring-boot-application ,这展示了如何开始使用Spring启动和Apache Kafka®,这里我们将更深入地挖掘Apache Kafka项目的Spring提供的一些附加功能。Apache Kafka的Sprin....

「首席架构师看Event Hub」Kafka的Spring 深入挖掘 -第1部分
问答 2023-05-09 来自:开发者社区

直接加入把db event push到kafka,最方便的做法改动哪块比较好?

把canal当databus用。目前是写个简易的canalClient,连接canal server指定的Destination, 但是这样client存在单点风险。 想直接把发送kafka消息集中到canal内,利用已有的zk 热备的模式,避免单点. cannal源码从哪块做改动,插入这个功能比较好? 原提问者GitHub用户liutaihua

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

产品推荐

云消息队列

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/

+关注