半兽人

多谢多谢。。

一起 yyds

大佬 yyds

你得把报什么错贴出来呀...

达咩

你的JDK的加密限制替换了吗？
还有ssl.endpoint.identification.algorithm=HTTPS
https://www.orchome.com/1822

你删除和加入权限的代码没有任何问题，这个主要是springboot的消费者加载问题。

1. java是静态语言，springboot第一次就初始化进行开始消费了。
2. 当你删除权限时，这个消费者组线程就结束了。

没有逻辑重新初始化这个消费者了，所以你需要重新启动这个微服务，进行重新初始化。

我个人觉得这个行为是非常正确的，权限一旦确认就不会反复修改，所以这个场景本身就非常非常少。

你想，什么情况下消费者组会脱离，oom或微服务宕机的时候才会脱离，本身就与进程共存亡的。所以也没有人去专门写个逻辑，去维护你这个场景。一直去尝试加入消费者试错权限才是最大的灾难。

结论:
max.request.size=104857600 是connector内部topic的prodcuer的配置.
producer.max.request.size=104857600 是connector source record 的prodcuer的配置.

zk是一个分布式文件系统，采用了类raft协议进行选举。很多多主式的分布式程序采用抢占zk节点的方式进行选举，这样就不必自己做raft这一部分了。有的程序也会在zk上注册节点存放一些元数据。
kafka 之前也是采用zk存放元数据，节点发现和进行选举等，这样各个节点间可以一定程度解耦。随着版本的更新，kafka逐渐将元数据放在broker中，以达到轻依赖的目的。2.8版本开放了kraft的试用模式，实现了类似es的raft选举方式，后续版本会逐步脱离zk的束缚。
但是这也会带来新的问题，后期kafka 扩容升级时涉及到主节点可能会变得麻烦，监控方案也是一个考验。

kafka自动提交offset主要由以下2个配置控制：

• enable.auto.commit: 是否开启自动提交offset功能。
• auto.commit.interval.ms：自动提交offset的时间间隔。

java消费者代码：

Properties props = new Properties();
props.setProperty("enable.auto.commit", "true");      // 开启自动提交
props.setProperty("auto.commit.interval.ms", "1000"); // 每隔1000ms提交一次。

例子可参考：kafka消费者Java客户端

https://github.com/kubernetes/kubernetes/issues/53533