阿里云文档 2024-12-06

调用GetConsumerList获取Group信息

调用GetConsumerList获取Group信息。

阿里云文档 2024-11-21

出现“Not authorized to access group”报错怎么办

本文为您介绍使用云消息队列 Kafka 版时出现Not authorized to access group错误信息的原因和解决办法。

阿里云文档 2024-11-14

消息队列Kafka版API的授权信息

访问控制(RAM)是阿里云提供的管理用户身份与资源访问权限的服务。使用RAM可以让您避免与其他用户共享阿里云账号密钥,并可按需为用户授予最小权限。RAM中使用权限策略描述授权的具体内容。本文为您介绍云消息队列 Kafka 版(AliKafka)为RAM权限策略定义的操作(Action)、资源(Res...

阿里云文档 2024-11-14

调用GetTopicList获取Topic信息

获取Topic信息。

问答 2023-05-04 来自:开发者社区

canal集成kafka后,每变更一次数据,会发送多次信息给kafka

我想变成每次修改只发送一次信息,请问我需要调整什么配置 原提问者GitHub用户haoshichong

问答 2023-05-03 来自:开发者社区

binglog 发送到 Kafka 怎样增加额外的信息表明消息源是哪里

要配置很多 边缘的 canal 实例发送到 集中部署 的 Kafka 集群。 在消息中怎样增加额外的信息表明 这个消息是来源于哪个 边缘端的 canal 实例吗? 原提问者GitHub用户leiwangouc

问答 2023-05-03 来自:开发者社区

使用原生的mq发到kafka,binlog日志的数据为什么没有偏移量信息。。写代码的时候可以拿到偏移

如题,之前写过代码试过拿binlog日志,可以拿到该条binlog日志的偏移量。但是使用原生的mq发送到kafka里时候,只有数据操作的一些信息,没有这条信息在binlog的偏移量。 原提问者GitHub用户everior

问答 2023-04-26 来自:开发者社区

flink 1.15.3 mysql cdc 2.3.0 同步到kafka 出现了这个异常信息Fa

flink 1.15.3 mysql cdc 2.3.0 同步到kafka 出现了这个异常信息Failed to deserialize data of EventHeaderV4{timestamp=1681910072000, eventType=WRITE_ROWS, serverId=2578535688, headerLength=19, dataLength=8182, nextP.....

问答 2023-03-27 来自:开发者社区

是在kafka集群的server.prope配置还是在kafka消费者的配置信息里 加入这个配置?

大佬们,在看帖子有说 Kafka的 隔离级别默认是 isolation.level 是 read_uncommitted,想修改成read_committed,该怎么配置? 是在kafka集群的server.properties配置文件里配置吗?还是在kafka消费者的配置信息里 加入这个配置就行?

文章 2022-06-14 来自:开发者社区

springboot中kafka配置信息记录

配置参考<dependency> <groupId>org.springframework.kafka</groupId> <artifactId>spring-kafka</artifactId> <version>2.3.8.RELEASE</version> &...

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

产品推荐

云消息队列

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

+关注