Docker化生产者向Kafka发消息失败，遇Schema Registry异常求助

我之前碰到过一模一样的问题！这个错误的核心根源很明确：你的生产者在请求Schema Registry时，收到的不是预期的JSON响应，而是HTML内容（大概率是错误页面，比如500或404的网页），所以JSON解析器碰到HTML的起始标签<就直接报错了。结合你用Docker Compose部署全链路的场景，给你几个针对性的排查和解决步骤：

1. 先确认Schema Registry的网络可达性（最常见的坑） #

因为所有服务都是Docker化部署，容器内部不能用宿主机的localhost或IP来访问Schema Registry，必须用Docker Compose中定义的服务名。比如你的Schema Registry在docker-compose.yml里的服务名是schemaregistry，那生产者配置里的schema.registry.url必须写成http://schemaregistry:8081——容器之间通过服务名在同一Docker网络内通信，这是Docker Compose的基础逻辑，很多人一开始会搞错成宿主机地址，导致容器内访问不到服务。

2. 验证Schema Registry本身是否正常运行 #

进入生产者容器，用curl直接测试Schema Registry的核心接口：

curl http://schemaregistry:8081/subjects

• 如果返回的是JSON格式的主题列表，说明服务正常；
• 如果返回HTML页面（比如包含<html>标签的内容），那说明Schema Registry自身启动失败或者有内部错误。这时候去看它的日志：

docker-compose logs schemaregistry

常见问题包括：

• KAFKA_BOOTSTRAP_SERVERS配置错误，导致Schema Registry连不上Kafka集群；
• Zookeeper未正常启动，Kafka集群状态异常；
• Schema Registry的存储目录权限问题（Docker容器内的权限配置）。

3. 检查生产者的Schema Registry配置细节 #

除了地址，还要确认这些配置项：

• 端口是否正确：Schema Registry默认是8081，别写成Kafka的9092端口；
• 协议是否匹配：如果没配置SSL，别把http写成https；
• 认证配置（如果开启了的话）：如果Schema Registry启用了基础认证，生产者必须配置对应的用户名密码：

  schema.registry.basic.auth.user.info=your-username:your-password
  schema.registry.basic.auth.credentials.source=USER_INFO
  

  没配置认证但Schema Registry要求认证的话，也会返回HTML错误页面。

4. 确认Docker网络的一致性 #

确保生产者容器和Kafka、Schema Registry在同一个Docker网络里。默认情况下，Docker Compose会为当前项目创建一个专属网络，所有服务自动加入。但如果你的生产者是单独的Compose文件或者手动指定了网络，需要显式把它加入到Schema Registry所在的网络中（在docker-compose.yml里用networks字段配置）。

按照这个顺序排查，基本上能定位到问题所在。我当时就是因为把Schema Registry的地址写成了宿主机IP，导致容器内访问不到，改回服务名就解决了。

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