Scala编写KafkaProducer时Avro序列化Schema Registry连接报错求解

你遇到的java.net.SocketException: Unexpected end of file from server异常，是Kafka Avro序列化器向Schema Registry服务自动注册Schema时，HTTP请求在收到完整响应前被强制断开导致，和你添加的依赖无关，属于网络连通性或服务配置不匹配类问题。

• Schema Registry服务未正常在18081端口启动：存在启动失败、端口被占用、服务进程崩溃的情况
• 网络访问受限：部署Producer的机器无法访问Schema Registry所在服务器的18081端口，防火墙、安全组未放行该端口
• Schema Registry地址配置错误：Producer端schema.registry.url参数写错协议（比如错用https）、IP/域名错误、多写了额外路径后缀
• Schema Registry开启了身份校验：Producer未配置对应的鉴权参数，请求被服务端直接拒绝断开

1. 先验证Schema Registry服务可用性和网络连通性
   在部署Producer的机器上执行命令：
   curl http://<Schema Registry所在服务器IP>:18081/schemas/types
   如果无法得到类似["JSON","PROTOBUF","AVRO"]的正常响应，先排查服务启动状态、防火墙/安全组规则，直到curl命令能正常返回结果。
2. 核对Producer配置项
   确认schema.registry.url参数值和你curl测试的地址完全一致，不要添加多余路径，协议和实际服务配置匹配。
3. 补充鉴权配置（如果Schema Registry开启了权限校验）
   在Producer配置中添加以下参数：

# 开启基础鉴权
basic.auth.credentials.source=USER_INFO
basic.auth.user.info=你的用户名:你的密码
# 若服务使用HTTPS协议，还要补充SSL证书相关配置

4. 验证Schema合法性
   确认你使用的Avro Schema和测试数据类型完全匹配，不存在字段类型不兼容、必填字段缺失的问题，避免Schema注册请求被服务端拒绝。

如果需要快速排除注册逻辑影响，可提前手动将Avro Schema上传到Schema Registry，然后在Producer配置中添加：

auto.register.schemas=false
use.latest.version=true

跳过自动注册环节直接用已存在的Schema做序列化。

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