-
查询用户/客户端流控配置 - 分布式消息服务Kafka版
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
-
Go - 分布式消息服务Kafka版
的基本信息页面中获取。如果SCRAM-SHA-512和PLAIN都开启了,根据实际情况选择其中任意一种配置连接。如果页面未显示“开启的SASL认证机制”,默认使用PLAIN机制。 非SASL认证方式 package main import ( "bufio" "fmt" "github
-
产品规格 - 分布式消息服务Kafka版
以内时推荐选用。 Kafka实例的存储空间估算参考 Kafka实例支持多副本存储,存储空间用于存储消息(包括副本中的消息)、日志和元数据。您在创建Kafka实例,选择初始存储空间时,建议根据业务消息体积预估、副本数量以及预留磁盘大小选择合适的存储空间。每个Kafka代理会预留33GB的磁盘空间,用于存储日志和元数据。
-
查询Kafka实例Topic详细信息 - 分布式消息服务Kafka版
kafka.v2.model.*; public class ShowInstanceTopicDetailSolution { public static void main(String[] args) { // The AK and SK used for
-
升级Kafka实例内核版本 - 分布式消息服务Kafka版
任务管理”页面。 在“后台任务”页签中,查看升级任务的状态。 当任务的“状态”为“成功”时,表示升级完成。 当任务的“状态”为“失败”时,表示升级失败,请联系客服处理。 定时执行 单击升级实例名称,进入实例详情页。 在左侧导航栏单击“后台任务管理”,进入“后台任务管理”页面。 在
-
消息超过老化时间,消息仍存在的原因 - 分布式消息服务Kafka版
nt文件的大小为500MB,当segment文件存储的消息大小到达500MB后,才会新建下一个segment文件。Kafka删除消息是删除segment文件,而不是删除一条消息。Kafka要求至少保留一个segment文件用来存储消息,如果正在使用的segment文件中包含超过老
-
查询Smart Connect任务列表 - 分布式消息服务Kafka版
"provenance_header_enabled" : false, "security_protocol" : "PLAINTEXT", "sasl_mechanism" : "PLAIN", "user_name" : "", "topics_mapping"
-
Java开发环境搭建 - 分布式消息服务Kafka版
信息”章节获取。 #SASL认证机制为“PLAIN”时,配置信息如下。 sasl.mechanism=PLAIN sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \
-
关闭Smart Connect - 分布式消息服务Kafka版
Connect,已删除的Smart Connect任务无法找回,需要重新创建。 前提条件 已创建Kafka实例,且实例状态为“运行中”。 关闭Smart Connect前,请先删除所有的Smart Connect任务,否则无法关闭Smart Connect。此操作是为了防止关闭Smart
-
删除用户/客户端流控配置 - 分布式消息服务Kafka版
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
-
返回结果 - 分布式消息服务Kafka版
000000", "domain_id": "d78cbac1..........", "xdomain_id": "30086000........", "xdomain_type": "", "
-
重置用户密码 - 分布式消息服务Kafka版
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
-
监控告警问题 - 分布式消息服务Kafka版
监控告警问题 云监控无法展示Kafka监控数据 Kafka监控显示消息堆积数跟实例里的消息数不一致? Kafka的消费组删除了,怎么监控页面还可以看到这个消费组?
-
重置密码 - 分布式消息服务Kafka版
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
-
创建消费组 - 分布式消息服务Kafka版
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
-
创建用户/客户端流控配置 - 分布式消息服务Kafka版
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
-
修改用户/客户端流控配置 - 分布式消息服务Kafka版
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
-
重置Manager密码 - 分布式消息服务Kafka版
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
-
批量添加或删除实例标签 - 分布式消息服务Kafka版
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
-
修改用户参数 - 分布式消息服务Kafka版
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great