如何配置Kafka以强制要求客户端必须设置client.id参数

有三种常用的落地方式可以实现该需求：

• Broker端自定义拦截器校验
  实现Kafka提供的BrokerInterceptor接口，重写消费者连接、元数据请求、消费请求对应的拦截方法，校验请求头中携带的client.id是否为空，为空直接返回错误响应拒绝请求。将开发完成的拦截器jar包放入所有broker节点的libs目录，修改server.properties配置添加interceptor.classes参数指向你的拦截器实现类，重启集群后生效。你也可以在校验逻辑中加入命名规则校验，只允许符合企业规范的client.id接入。
• 自定义授权器校验
  如果你已经开启了Kafka集群的ACL权限控制，可以自定义Authorizer接口的实现类，在消费者请求消费权限的逻辑中增加client.id非空校验，为空则直接返回权限拒绝，没有配置client.id的消费者将无法获取任何topic的消费权限。
• 统一SDK封装管控
  如果是企业内部使用的Kafka集群，可以统一封装官方的消费者SDK，在SDK初始化逻辑中强制校验client.id参数是否传入，未传入则直接抛出异常终止初始化，从业务使用的源头规避未配置client.id的情况，该方案落地成本最低，还可以配套加入其他企业级管控规则。

注意：broker端的插件需要和你当前集群的Kafka版本保持API兼容，避免启动异常。

内容的提问来源于stack exchange，提问作者Raman