如何快速使用云消息队列 Kafka 的Java SDK收发消息

六分钟上手 云消息队列 Kafka 。文档教程 快速入门

迁移数据上云

云消息队列 Kafka 集群的SSL接入点(可在 云消息队列 Kafka 控制台获取)bootstrap.servers=XXX.XXX.XXX.XXX:9093#数据压缩方式 compression.type=none#truststore(使用步骤1下载的文件)ssl.truststore.location=kafka.client....

迁移Group上云

本文介绍如何使用 云消息队列 Kafka 提供的迁移工具将自建Kafka集群的 Group 迁移到 云消息队列 Kafka 实例。前提条件 您已完成以下操作:下载JDK 8 下载迁移工具kafka-migration-assessment.jar 购买并部署 云消息队列 Kafka ...

是否支持延迟消息

和开源Apache Kafka一样,云消息队列 Kafka 同样不支持延迟消息。

计费概述

说明 云消息队列 Kafka 的Connector组件依赖于 事件总线,云消息队列 Kafka 不会额外收取费用。事件总线 的计费说明,请参见 计费说明。同时,阿里云不承诺Connector的SLA,使用Connector所依赖的其他产品的SLA和费用说明请以对应...

自由使用Group

前提条件 您已购买并部署 云消息队列 Kafka 实例,且该实例必须满足以下条件:项目 说明 状态 服务中。版本 大版本为2.2.0,且小版本为最新版本。说明 您可以在 云消息队列 Kafka 控制台的 实例详情 页面的 基础信息 区域查看实例的...

上迁移Topic

本文介绍如何使用 云消息队列 Kafka 提供的迁移工具将某个 云消息队列 Kafka 实例的Topic迁移到另一个 云消息队列 Kafka 实例。前提条件 您已完成以下操作:下载JDK 8 下载迁移工具kafka-migration-assessment.jar 购买并部署 ...

无法ping通云消息队列 Kafka 的接入点

问题描述 无法ping通云消息队列 Kafka 的接入点。本地客户端无法telnet Kafka或提示连接超时(Connection timed out)。问题原因 为了保证安全,云消息队列 Kafka 集群默认禁ping。连接VPC接入点时,客户端与Kafka不在同一VPC下。解决...

如何通过代理访问云消息队列 Kafka 实例

概述 暂不支持通过代理访问云消息队列 Kafka 实例,具体请查看 详细信息。详细信息 云消息队列 Kafka 的客户端访问服务端的原理如下。通过 bootstrap.servers 随机访问服务器获取Metadata。通过Metadata里的IP地址进行后续的消息收发。...

接入点对比

云消息队列 Kafka 提供默认接入点、SSL接入点和SASL接入点以适用不同的连接及安全需求。默认接入点适用于在保密性较高的VPC环境收发消息;SASL接入点适用于无需对传输链路加密但需对消息收发鉴权;需要链路加密和消息鉴权,建议使用SSL...

服务支持

本文汇总了 云消息队列 Kafka 的常见问题与以及服务等级协议。服务支持 常见问题 相关协议

云监控

前提条件 创建服务关联角色 角色名称:AliyunServiceRoleForAlikafka 角色策略名称:AliyunServiceRolePolicyForAlikafka 权限说明:允许 云消息队列 Kafka 使用该角色访问您的服务(云监控和ARMS服务)以完成云监控和仪表盘相关功能。...

查看任务执行记录

在某个实例下发起重启类任务(包括配置变更、版本升级、开启ACL、实例升配)后,您可以在 云消息队列 Kafka 控制台查看重启类任务的执行记录,帮助您跟踪任务进展、定位服务端异常重启原因等。前提条件 创建并部署 云消息队列 Kafka ...

消息检索

云消息队列 Kafka 控制台提供的按位点查询和按时间查询消息的功能无法满足您搜索消息的需求时,您可以使用 云消息队列 Kafka 消息检索功能。消息检索支持按Topic分区、位点范围、时间范围以及消息Key和Value关键字检索。本文介绍...

如何获取部署实例时需要的VPC信息?

在 交换机 页面,查看以下信息:交换机 实例ID/名称 专有网络 可用区 说明 请根据该页面的可用区(A~G)在 云消息队列 Kafka 控制台中选择对应的可用区(A~G)。例如,某VPC交换机(vSwitch)显示在 可用区B,那么在 云消息队列 Kafka...

配置白名单

您可以设置访问 云消息队列 Kafka 的白名单,配置在白名单中的IP地址与端口才允许访问 云消息队列 Kafka 实例。前提条件 您已购买 云消息队列 Kafka 实例,且该实例处于 服务中 的状态。注意事项 公网/VPC类型的实例默认白名单为0...

Topic的存储有哪些类型?

云存储和Local存储。云消息队列 Kafka 实例支持云存储和Local存储。详情请参见 存储引擎对比。

查看消费明细

如果您对 云消息队列 Kafka 服务的消费情况产生疑问,可以查看消费明细。查看费用账单 登录 云消息队列 Kafka 控制台。在页面右上角,选择 费用>用户中心。在左侧导航栏,按需选择 账单管理 目录下的账单维度,查看您的消费信息。月...

元数据导入

本文介绍如何在 云消息队列 Kafka 控制台创建元数据导入任务,将元数据迁移至 云消息队列 Kafka 已有实例。前提条件 下载JDK 8 购买并部署云消息队列 Kafka 实例:购买并部署VPC实例 购买并部署公网/VPC实例 说明 购买实例的规格可...

为什么Group的状态一直处于“删除中”?

问题现象 在 云消息队列 Kafka 控制台 的 Group 管理 页面删除Group后,此Group的状态一直处于 删除中。可能原因 Group中存在活跃的订阅关系。Group上有消费线程在提交新的消费位点。解决方案 登录 云消息队列 Kafka 控制台,查看...

查看任务执行记录

在某个实例下发起重启类任务(包括实例升降配、定时任务)后,您可以在 云消息队列 Kafka 控制台查看该实例的重启类任务的执行记录,获取任务的类型、开始执行时间、结束执行时间、状态等信息。前提条件 创建并部署 云消息队列 Kafka ...

开发参考

本文介绍 云消息队列 Kafka 的SDK和API及Terraform的支持情况,供您进行对应的开发操作。开发参考 API参考指南 SDK参考 Terraform

实践教程

针对各种业务需求,云消息队列 Kafka 提供相关的实践教程,您可以根据本文查看适合您业务的实践教程文档。实践教程 最佳实践 生态对接

设置实例到期欠费预警提醒通知

欠费预警接收设置 登录 云消息队列 Kafka 控制台。单击页面右上方的 图标,进入 消息中心 页面。在左侧导航栏,单击 基本接收管理。在 基本接收管理 页面的 消息类型 中勾选 产品的欠费、停服、即将释放相关信息通知,单击 修改。在 ...

云监控

前提条件 创建服务关联角色 角色名称:AliyunServiceRoleForAlikafka 角色策略名称:AliyunServiceRolePolicyForAlikafka 权限说明:允许 云消息队列 Kafka 使用该角色访问您的服务(云监控和ARMS服务)以完成云监控相关功能。...

使用Kafka Connect将SQL Server数据同步至云消息队列 ...

本教程介绍如何使用Kafka Connect的Source Connector将SQL Server的数据同步至 云消息队列 Kafka 。前提条件 在开始本教程前,请确保您已完成以下操作:已下载SQL Server Source Connector。具体信息,请参见 SQL Server Source ...

迁移自建Kafka集群至新实例

您可以将自建Kafka集群元数据导出,然后导入 云消息队列 Kafka 实例,云消息队列 Kafka 会根据成功导入的元数据在目标 云消息队列 Kafka 实例中创建对应的Topic和Group,实现自建Kafka集群元数据迁移上云。导出元数据 使用元数据...

报警项状态显示数据不足怎么办?

可能原因 老版 云消息队列 Kafka 实例不支持报警数据上报。解决方案 登录 云消息队列 Kafka 控制台。在 概览 页面的 资源分布 区域,选择地域。在 实例列表 页面,单击目标实例名称。在 实例详情 页面,单击 配置信息 页签,然后单击...

Filebeat发送失败问题

问题现象 在 云消息队列 Kafka 控制台 的 Topic 管理 页面,您已成功创建Topic,但使用Filebeat向该Topic发送消息却出现 Request was for a topic or partition that does not exist on this broker.的错误提示。可能原因 Filebeat向...

作为Output接入

云消息队列 Kafka 可以作为Output接入Logstash。本文说明如何在VPC环境下通过Logstash向 云消息队列 Kafka 发送消息。前提条件 购买并部署 云消息队列 Kafka 实例。具体操作,请参见 VPC接入。下载并安装Logstash。具体操作,请...

为什么在控制台看不到Group的订阅关系?

问题现象 您已启动某个Group的消费线程,但在 云消息队列 Kafka 控制台 的 Topic 详情 页面的 订阅关系 页签,查不到Topic被Group订阅的信息,或者在 Group 详情 页面的 消费状态 页签,查不到该Group订阅的Topic信息。可能原因 客户端...

公网和VPC接入

如果需要同时在VPC网络和公网接入 云消息队列 Kafka ,您需要购买并部署公网/VPC实例。前提条件 已授予 云消息队列 Kafka 访问其他云服务资源的权限。具体信息,请参见 获取访问授权。已搭建VPC网络。具体操作,请参见 创建和管理专有...

作为Input接入

云消息队列 Kafka 可以作为Input接入Filebeat。本文说明如何在VPC环境下通过Filebeat从 云消息队列 Kafka 消费消息。背景信息 在开始本教程前,请确保您已完成以下操作:购买并部署 云消息队列 Kafka 实例。具体操作,请参见 VPC...

接入Logstash

本文介绍如何将 云消息队列 Kafka 接入Logstash。Logstash Logstash是开源的服务器端数据处理管道,能够同时从多个数据源采集数据,然后对数据进行转换,并将数据写入指定的存储中。Logstash的数据处理流程如下:输入:采集各种格式、...

【通知】V2系列Serverless实例退市公告

云消息队列 Kafka V2系列Serverless实例将于2024年02月28日正式下线,如您目前仍在使用此类型实例,请尽快迁移至V3系列Serverless实例。停止维护 感谢您对 云消息队列 Kafka V2系列Serverless实例的支持!为了提供更稳定、更高性能的...

作为Input接入

云消息队列 Kafka 可以作为Input接入Logstash。本文说明如何在VPC环境下通过Logstash从 云消息队列 Kafka 消费消息。前提条件 在开始本教程前,请确保您已完成以下操作:购买并部署 云消息队列 Kafka 实例。具体操作,请参见 VPC...

VPC接入

如果仅需要在VPC网络接入 云消息队列 Kafka ,您可以购买并部署VPC实例。前提条件 已授予 云消息队列 Kafka 访问其他云服务资源的权限。具体信息,请参见 步骤一:获取访问授权。已搭建VPC网络。具体操作,请参见 创建和管理专有网络...

如何进行发送消息的测试?

您可以直接在 云消息队列 Kafka 控制台进行发送消息的测试。您可以在控制台的 Topic管理 页面,单击目标Topic右侧的 发送消息,进行消息发送测试,以验证集群是否运转正常。

自动创建Topic

自动创建Topic是指当 云消息队列 Kafka 实例发送请求以获取不存在的Topic元数据时,例如向不存在的Topic发送生产请求,云消息队列 Kafka 可以自动创建Topic。自动创建Topic适用于迁移上云场景或测试场景,无需手动重复创建Topic,...

迁移上云

云消息队列 Kafka 提供全托管、免运维的迁移上云服务,用于自建实例或跨云云实例与 云消息队列 Kafka 实例之间的数据同步。本文介绍迁移上云的源实例类型、使用限制、跨VPC数据同步以及使用流程。前提条件 您已购买并部署 云消息队列...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
云监控 云消息队列 Kafka 版 开源大数据平台 E-MapReduce 视图计算 轻量应用服务器 弹性公网IP
新人特惠 爆款特惠 最新活动 免费试用