Producer 将消息发往Kafka Topic中的角色称为Producer。 Consumer 从Kafka topic中获取消息的角色称为Consumer。 Broker Kafka集群中的每一个节点 服务器 称为Broker。 keytab file 存放用户信息的密钥文件。应用程序

查看更多 →

G配置的时间，默认为1000毫秒），服务端才会认为此消费者已下线。 查看消费进度（控制台） 登录管理控制台。 在管理控制台左上角单击，选择区域。 请选择Kafka实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务Kafka版”，进入分布式消息服务Kafka专享版页面。

查看更多 →

退出，会导致Consumer频繁做rebalance，阻塞消费。 Consumer数量不能超过Topic分区数，否则会有Consumer拉取不到消息。 Consumer需周期poll，维持和server的心跳，避免心跳超时，导致Consumer频繁加入和退出，阻塞消费。 Cons

查看更多 →

部分老实例不支持修改配置参数，具体以控制台为准，此时请联系客服解决。 单机版实例不支持修改配置参数。 前提条件 Kafka实例的状态为“运行中”时，才能修改配置参数。 修改Kafka实例配置参数 登录管理控制台。 在管理控制台左上角单击，选择区域。 请选择Kafka实例所在的区域。 在管理控制台左上角单击，选择“应用中间件

查看更多 →

通过IntelliJ IDEA可直接运行Consumer.java，如图1所示： 图1 运行Consumer.java 单击运行后弹出控制台窗口，可以看到Consumer启动成功后，再启动Producer，即可看到实时接收消息： 图2 Consumer.java运行窗口 在Linux调测程序

查看更多 →

网络正常，如下： 网络异常/不通，如下： 解决方案： 检查是否同一个VPC。如果不是，请参考跨VPC访问。 检查安全组规则是否配置正确。请参考如何选择和配置安全组。 检查Consumer和Producer的配置 查看日志，检查Consumer和Producer初始化时打印的参数是否符合预期，是否和自己在配置文件中设置的一致。

查看更多 →

延迟、可靠性和持久性。它被广泛应用于大数据处理、实时数据流处理、日志收集等领域。 创建Kafka连接 登录新版ROMA Connect控制台。 在左侧导航栏选择“连接器”，在连接器页面单击“新建连接”。 选择“Kafka”连接器。 在弹窗中配置连接器信息，完成后单击“确定”。 参数

查看更多 →

在Kafka控制台的“基本信息 > 连接信息”中获取实例连接地址。Kafka实例连接地址在Kafka控制台存在两种不同的显示，一种为“内网连接地址”/“公网连接地址”，另一种为“内网密文连接地址”/“公网密文连接地址”，具体以控制台显示为准。 如果是使用内网通过同一个VPC访问，Kafka连接地址如下图所示。

查看更多 →

云服务器控制台管理 权限 对应的API接口 授权项（Action） 依赖的授权项 IAM项目 (Project) 企业项目 (Enterprise Project) 实例授权 标签授权 获取控制台VNC地址 POST /v2.1/{project_id}/servers/{ser

查看更多 →

云服务器控制台管理 获取弹性云服务器的控制台日志 获取VNC远程登录地址（微版本2.6及以上） 父主题： API（OpenStack Nova 原生）

查看更多 →

通过IntelliJ IDEA可直接运行Consumer.java，如图1所示： 图1 运行Consumer.java 单击运行后弹出控制台窗口，可以看到Consumer启动成功后，再启动Producer，即可看到实时接收消息： 图2 Consumer.java运行窗口 在Linux调测程序

查看更多 →

新建集群Consumer消费数据失败，提示“GROUP_COORDINATOR_NOT_AVAILABLE” 问题背景与现象 新建Kafka集群，部署Broker节点数为2，使用Kafka客户端可以正常生产，但是无法正常消费。Consumer消费数据失败，提示GROUP_COOR

查看更多 →

使用Consumer API订阅安全Topic并消费 功能介绍 下面代码片段在com.huawei.bigdata.kafka.example.Consumer类中，用于实现使用Consumer API订阅安全Topic，并进行消息消费。 代码样例 /** * Consumer构造函数。

查看更多 →

通过API或kubectl操作CCE集群，创建的资源是否能在控制台展示？ 在CCE控制台，暂时不支持显示的kubernetes资源有：DaemonSet、 ReplicationController、ReplicaSets、Endpoints等。 若需要查询这些资源，请通过kubectl命令进行查询。

查看更多 →

本文以Linux系统的弹性云服务器（Elastic Cloud Server，简称E CS ）作为生产消费客户端。在创建Kafka实例前，请先创建开启弹性公网IP的ECS、安装JDK、配置环境变量以及下载Kafka开源客户端。 登录管理控制台，在左上角单击，选择“计算 > 弹性云服务器”，创建一个ECS实例。

查看更多 →

怎样修改云服务器子网的网段？ 操作场景 子网创建好后，网段是不支持修改的。 如需修改子网网段可以通过更换子网来实现。 前提条件 云服务器已关机。 操作步骤 登录管理控制台。 选择“计算 > 弹性云服务器”。 在弹性云服务器列表中的右上角，输入弹性云服务器名、IP地址或ID，并单击进行搜索。

查看更多 →

同一子网内。 已加入ELB后端服务器组的裸金属服务器，需要先移除才能修改私有IP地址。 操作步骤 登录管理控制台。 选择“计算 > 裸金属服务器”。 在裸金属服务器列表中的右上角，输入裸金属服务器名称、私有IP地址、ID或规格，并单击进行搜索。 单击待修改私有IP的裸金属服务器名称。

查看更多 →

约束与限制 弹性云服务器已关机。 如果网卡绑定了虚拟IP或者DNAT规则，需要先解绑。 如果网卡上有IPv6地址，无法修改（包括IPv4和IPv6的）私有IP地址。 如需修改弹性负载均衡后端服务器的私有IP地址，请先移出后端服务器组后再修改私有IP。 操作步骤 登录管理控制台。 单击“”，选择“计算

查看更多 →

使用Consumer API订阅安全Topic并消费 功能简介 下面代码片段在com.huawei.bigdata.kafka.example.Consumer类中，用于实现使用Consumer API订阅安全Topic，并进行消息消费。 代码样例 /** * Consumer构造函数。

查看更多 →

3G静态IP地址不能与本地IP地址在同一网段 0x02002011: 3G静态IP地址不能与辅IP地址在同一网段 0x02002012: 本地IP与辅助IP不能在同一网段 0x02002013: 辅IP与辅子网掩码必须同时为空或者同时不为空 0x02002014: DNS服务器地址非法 0x02002015:

查看更多 →

DCS实例是否支持跨VPC访问？ 跨VPC访问，即客户端和实例不在同一个VPC。 对于未开启公网访问的实例，一般情况下，不同VPC间网络不互通，不在同一VPC下的弹性云服务器无法访问DCS缓存实例。 可以通过创建VPC对等连接，将两个VPC的网络打通，实现跨VPC访问DCS缓存实例。

查看更多 →