-
使用MirrorMaker跨集群同步数据 - 分布式消息服务Kafka版
# 指定两个集群 clusters = A, B A.bootstrap.servers = A_host1:A_port, A_host2:A_port, A_host3:A_port B.bootstrap.servers = B_host1:B_port, B_host2:B_port
-
登录Kafka Manager的帐号是否可以设置为只读帐号? - 分布式消息服务Kafka版
登录Kafka Manager的帐号是否可以设置为只读帐号? 不支持设置为只读帐号。 父主题: Kafka Manager问题
-
Kafka Manager和云监控显示的信息不一致 - 分布式消息服务Kafka版
Kafka Manager和云监控显示的信息不一致 问题现象:在后台删除某个消费组后,在云监控已经不显示此消费组,但是Kafka Manager中依然存在。 问题原因:Kafka Manager存在缓存。
-
使用DNAT实现公网访问Kafka - 分布式消息服务Kafka版
将“advertised.listeners IP/域名”改为DNAT规则中的弹性公网IP,内网连接地址和弹性公网IP的对应关系与添加DNAT规则中记录的对应关系保持一致,单击“保存”。
-
使用客户端连接Kafka(明文接入) - 分布式消息服务Kafka版
/kafka-console-consumer.sh --bootstrap-server 10.xx.xx.45:9094,10.xx.xx.127:9094,10.xx.xx.103:9094 --topic topic-demo --group order-test --from-beginning
-
Yikes! Insufficient partition balance when creating topic : projectman - 分布式消息服务Kafka版
父主题: Kafka Manager问题
-
在Windows服务器中无法登录Kafka Manager - 分布式消息服务Kafka版
在Windows服务器中无法登录Kafka Manager 问题现象 在Windows服务器的浏览器中输入Kafka Manager地址,无法登录Kafka Manager,报错信息如下图。
-
分布式消息服务Kafka版 - 分布式消息服务Kafka版
命令行模式连接 连接未开启SASL的实例 连接已开启SASL的实例 客户端方式连接 Java客户端 Python客户端 Go客户端 05 实践 Kafka作为一款热门的消息队列中间件,广泛应用于企业解决方案、金融支付、电信、电子商务、社交、即时通信、视频、物联网、车联网等众多领域。
-
生产或消费消息时,报Topic {{topic - 分布式消息服务Kafka版
} not present in metadata after 60000 ms的错误,如下图所示。
-
为什么实例中存在默认名为 - 分布式消息服务Kafka版
为什么实例中存在默认名为__trace和__consumer_offsets的Topic? 问题现象:Kafka Manager中存在默认名为__trace和__consumer_offsets的Topic。
-
实例版本在控制台和Kafka Manager上显示不一致? - 分布式消息服务Kafka版
实例版本在控制台和Kafka Manager上显示不一致? Kafka实例的版本以控制台为准。Kafka Manager使用了开源Kafka 2.2.0的公共信息配置,所以显示的版本是2.2.0,和购买的Kafka实例版本没有关系。 父主题: 实例问题
-
客户端删除消费组后,在Kafka Manager中仍可以看到此消费组? - 分布式消息服务Kafka版
客户端删除消费组后,在Kafka Manager中仍可以看到此消费组? 客户端删除消费组后,此消费组已经被删除了。在Kafka Manager中仍可以看到此消费组,是因为Kafka Manager存在缓存。 通过以下任意一种方法解决此问题: 重启Kafka Manager。
-
申请扩大Kafka配额 - 分布式消息服务Kafka版
为防止资源滥用,平台限定了各服务资源的配额,对用户的资源数量和容量做了限制。如您最多可以创建多少个Kafka实例。 如果当前资源配额限制无法满足使用需要,您可以申请扩大配额。 怎样查看我的配额? 登录管理控制台。 单击管理控制台左上角的,选择区域和项目。
-
扩容/缩容过程中生产消息失败 - 分布式消息服务Kafka版
在重启过程中,分区Leader会进行切换,此时生产客户端的元数据缓存中保存的分区Leader为旧分区Leader ID,仍然会向旧分区Leader发送消息,导致生产消息失败。 解决方法:在生产客户端配置重试机制。
-
为什么可用区不能选择2个? - 分布式消息服务Kafka版
原因如下: 每个Kafka实例包含3个Zookeeper节点,Zookeeper集群用来管理Kafka实例的配置,如果Zookeeper集群出现问题,Kafka实例将无法正常运行。至少2个Zookeeper节点正常运行,才能保证Zookeeper集群正常运行。
-
查看Kafka消费者信息 - 分布式消息服务Kafka版
Kafka Manager由于缓存原因,显示的消费者连接地址可能不是当前消费者连接地址,建议重启Kafka Manager解决。 2023年5月17日及以后创建的实例不提供Kafka Manager功能,不支持在Kafka Manager中查看消费者连接地址。
-
重置用户密码 - 分布式消息服务Kafka版
= "Cxxx3" request.Body = &model.ResetUserPasswrodReq{ NewPassword: &newPasswordResetUserPasswrodReq, } response, err := client.ResetUserPasswrod
-
修改用户参数 - 分布式消息服务Kafka版
{ UserDesc: &userDescUpdateUserReq, UserName: &userNameUpdateUserReq, NewPassword: &newPasswordUpdateUserReq, } response, err := client.UpdateInstanceUser
-
产品规格 - 分布式消息服务Kafka版
实例规格以实例提供的ECS规格分类,具体如下: 集群版实例 kafka.2u4g.cluster.small kafka.2u4g.cluster kafka.4u8g.cluster kafka.8u16g.cluster kafka.12u24g.cluster kafka.16u32g.cluster
-
Kafka客户端参数配置建议 - 分布式消息服务Kafka版
buffer.memory 33554432 67108864 producer可以用来缓存数据的内存大小。如果数据产生速度大于向broker发送的速度,producer会阻塞或者抛出异常,以“block.on.buffer.full”来表明。