微服务

使用钉钉扫一扫加入圈子

构建可靠、高效、易扩展的技术基石

分享微服务技术领域的最新动态、技术实践、行业洞察、活动等,包括但不限于微服务框架、分布式消息、注册中心、配置中心、分布式事务、可靠性、监控、链路追踪等,致力于打造学习、交流、可进阶的微服务技术社区。
1. 如果是首次接入,请根据语言选择合适的sdk进行操作
在代码接入前,需要做到
  • 与接入点的网络连通性,telnet 通接入点 端口号(可以先关闭防火墙黑名单等设置);本地调试开发请使用公网接入点。
  • 检查用户名密码是否设置正确。
    5.0系列实例:需要填写实例的用户名和密码,在控制台实例详情页获取。
    4.0系列实例:需要填写阿里云账号或RAM用户的AccssKey(AccessKey ID和AccessKey Secret)并正确授权。获取方式,请参见 创建AccessKey
  • 提前在控制台上创建topic和group.
  • 保证代码中的各参数正确,接入点,topic名称,group名称,注意是否有前后空格,特殊符号
  • 4.0系列如果是子账号,需要先授权,参考 权限策略和示例

2. 如果是已经成功接入,后来断线,请检查
  • 本地网络与接入点的连通性,程序是否正常运行,是否有由于full GC导致带宽打满等客户端情况
  • 可能由于升级导致,是否处于升级时段可以查看 公告列表的升级公告一栏


社区答人 评论 0
1.可以先通过 设备轨迹查询断线的原因,一般可能是未授权,推荐按照 快速使用MQTT.fx模拟SDK收发消息重新进行操作。
2.如果使用签名验证,请确认用户名、密码是否正确。可通过控制台签名验证功能,使用开发者Accesskey,Secrectkey生成签名的用户名、密码。
3.请确认Clientid设置符合微消息队列MQTT版的命名规范。
4.请确认订阅的Topic已存在。
社区答人 评论 0
可以使用 Pipeline(流水线)方式进行配置Jenkins插件,因为脚本式的部署配置可以通过变量来动态控制镜像地址。
社区答人 评论 0
如果修改配置后应用里没有生效,添加下注解@RefreshScope。
社区答人 评论 0

1

回答

提个问题 2024-06-14 196浏览量 回答数 1

可以通过DeleteConsumerGroup接口删除Group,详细流程请点此进入查看。也可以直接在控制台进行删除group管理-操作列-更多-删除。请注意删除 Group 带来的影响。

社区答人 评论 0
可能原因是:
1.当时kafka coordiantor出现切换,导致flink作业会提交offset失败,不会影响作业的运行。
这个是已知的开源 Kafka缺陷,目前Flink社区通过升级kafka版本在Flink1.16上 修复。目前VVP如果要恢复提交位点需要重启作业,待Flink 全托管产品发布Flink 1.16 后进行升级处理。
2.当时checkpoint失败没有汇报消费位点,因为kafka是依赖checkpoint来提交offset位点的。


社区答人 评论 0
已经全部加载了,小花花送你

阿里云MVP

王洋

小红唇(北京)网络科技有限公司 技术总监

陈炜钊

金融行业 高级研发专员

郭迪鸣

广州鹰云信息科技 研发中心总监

曾红

重庆妙享网络技术 技术总监

肖林岩

润联软件 技术副总监

杨旭

安徽数加信息科技 架构师/高级讲师

武让

万孚生物 智能互联部负责人

江同飞

云族佳 CTO

郭联钰

高级软件工程师

刘凡

北京好雨科技有限公司 CEO

陈凯玲

TapTap 中间件工程师

陈健飞

上海汇付数据服务有限公司 资深架构师

石恩名

数智天玑信息技术有限公司 CTO

杨虎

深圳市一号互联科技有限公司 技术总监

郦强

众基网络 技术合伙人

杨福海

CEO

杨毓丞

北京知藏云道科技有限公司 架构师

王海能

特步 技术总监

曾昌强

成都库珀区块链科技有限公司 联盟链负责人

李祺

慧科教育科技集团有限公司 总经理

亓世金

联想 系统架构师
展开

近期公开课 全部