消息队列Kafka版API的版本说明
变更时间:2025-04-22变更集发布说明:OpenAPI 名称变更内容概要操作GetConsumerProgressOpenAPI 错误码发生变更、OpenAPI 返回结构发生变更。查看变更详情查看API文档变更时间:2025-04-09变更集发布说明:OpenAPI 名称变更内容概要操作Get...
消息队列Kafka版API的公共错误码
错误码HTTP status code错误码错误信息描述操作400ADMIN_GET_BROKER_CONFIG_ERROR%s. Please check and try again later.获取Broker配置失败。请联系管理员。诊断400ADMIN_UPDATE_BROKER_CONFIG...
消息队列Kafka版API的授权信息
访问控制(RAM)是阿里云提供的管理用户身份与资源访问权限的服务。使用RAM可以让您避免与其他用户共享阿里云账号密钥,并可按需为用户授予最小权限。RAM中使用权限策略描述授权的具体内容。本文为您介绍云消息队列 Kafka 版(alikafka)为RAM权限策略定义的操作(Action)、资源(Res...
Kafka Consumer java api 配置
Kafka Consumer java api 配置: group.id: 指定consumer所属的consumer group consumer.id: 如果不指定会自动生成 socket.timeout.ms: 网络请求的超时设定 socket.receive.buffer.bytes: Socket的接收缓存大小 fetch.m...
kafka Consumer high-level api 之白名单
Kafka提供了两套API给Consumer The high-level Consumer API The SimpleConsumer API 第一种高度抽象的Consumer API,它使用起来简单、方便,但是对于某些特殊的需求我们可能要用到第二种更底层的API,那么下面来介绍下第一种API: 使用白名单...
探究Kafka原理-4.API使用
练习需求:写一个生产者,不断地去生成“用户行为事件” 并写入kafka{“guid”:1,“eventId”:“pageview”,“timestamp”:163786834789}{“guid”:1,“eventId”:“pageview”,“timestamp”:163786834789}{“guid”:1,“eventId”:“pageview”,“timestamp”:163786834....

探究Kafka原理-3.生产者消费者API原理解析(下)
探究Kafka原理-3.生产者消费者API原理解析(上):https://developer.aliyun.com/article/1413716Cooperative Sticky Strategy对应的类叫做: org.apache.kafka.clients.consumer.ConsumerPartitionAssignor(最新的一种 2.4.1)sticky 策略的特点:逻辑与 st....

探究Kafka原理-3.生产者消费者API原理解析(上)
API 开发:producer 生产者生产者 api 示例一个正常的生产逻辑需要具备以下几个步骤(1)配置生产者参数及创建相应的生产者实例(2)构建待发送的消息(3)发送消息(4)关闭生产者实例首先,引入 maven 依赖<dependency> <groupId>org.apache.kafka</groupId> <artifactId>...

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