Hi， 定期改密码，那其他团队也应该遇到类似的情况吧
1. 首先参考下其他团队的解决办法； 2. 个人感觉可以参考改写kafka的connector，遇到了密码错误的情况，就去加载新的密码，关闭旧的client，重新创建client，之前的offset可以单独保存，新创建的可以从offset继续消费； 3. 流程上规避，在修改kafka密码的流程中，先停掉flink任务，修改密码后，再启动flink任务； 在 2025-02-25 10:49:15，"曲洋" <quyanghao...@126.com> 写道： >Hi，各位大佬大家好， >我想请教一个问题，由于公司的安全策略，需要定期更改Kafka的密码，这个会导致Flink应用直接挂掉，我们在网上还没有找到任何资料或者策略可以应对Kafka密码的定期变更（比如一周一次） >想请教一下现在有没有什么好的解决方案，可以支持Flink连接Kafka的热变更，感谢感谢
