Spring Data Cassandra对接Amazon Keyspace遇MalformedInputException求解

1. 显式配置字符串编解码器的UTF-8字符集，或使用容错解码 #

异常源于字符串解码时遇到无效字节序列，显式指定UTF-8编码并开启容错处理，既能避免抛出异常，也能定位问题数据：

方式1：在配置文件中指定字符集 #

修改keyspaces-application.conf，添加编解码器配置：

datastax-java-driver {
  # 原有配置...
  advanced.codec-registry {
    codecs = [
      {
        class = com.datastax.oss.driver.internal.core.type.codec.StringCodec
        parameters = { charset = "UTF-8" }
      }
    ]
  }
}

方式2：自定义容错编解码器 #

创建能处理无效字节的字符串编解码器，替换默认实现：

import com.datastax.oss.driver.api.core.type.codec.StringCodec
import com.datastax.oss.driver.api.core.type.codec.CodecContext
import java.nio.ByteBuffer
import java.nio.charset.StandardCharsets
import java.nio.charset.CodingErrorAction

class TolerantStringCodec : StringCodec(StandardCharsets.UTF_8) {
    override fun decode(bytes: ByteBuffer?, context: CodecContext?): String? {
        if (bytes == null || bytes.remaining() == 0) {
            return null
        }
        val decoder = StandardCharsets.UTF_8.newDecoder()
            .onMalformedInput(CodingErrorAction.REPLACE)
            .onUnmappableCharacter(CodingErrorAction.REPLACE)
        return decoder.decode(bytes.duplicate()).toString()
    }
}

然后注册该Codec到驱动：

import org.springframework.context.annotation.Bean
import org.springframework.context.annotation.Configuration
import com.datastax.oss.driver.api.core.type.codec.CodecRegistry

@Configuration
class CassandraCodecConfig {
    @Bean
    fun codecRegistry(): CodecRegistry {
        return CodecRegistry.DEFAULT.withCodecs(TolerantStringCodec())
    }
}

这样查询时会将无效字符替换为�，不会抛出异常，方便定位问题数据。

2. 修复连接池污染问题（间歇性错误+重启恢复的核心方向） #

间歇性错误且重启后恢复，大概率是连接池中的某个连接被污染（字节流异常），配置连接池的自动清理与验证机制：

修改keyspaces-application.conf：

datastax-java-driver {
  # 原有配置...
  advanced.connection {
    # 限制连接最大生命周期，避免长期使用同一连接
    max-life-time = 1 hour
    max-idle-time = 5 minutes
    pool {
      local {
        size = 3
        # 定期清理闲置连接
        eviction-interval = 1 minute
        idle-timeout = 5 minutes
        # 获取连接时验证有效性，丢弃异常连接
        test-on-borrow = true
        query = "SELECT now() FROM system.local"
      }
    }
  }
}

3. 升级Datastax驱动版本 #

当前使用的java-driver-core-4.17.0可能存在连接或解码相关的已知bug，升级到同系列的稳定新版本（如4.17.6），同时确保Spring Data Cassandra与驱动版本兼容（spring-data-cassandra-4.1.2兼容4.15+版本的驱动）。

4. 验证表结构与数据合理性 #

• 用CQL查询表结构，确认所有字符串字段类型为text而非blob：

  DESCRIBE TABLE organization;
  

  若字段类型为blob，驱动按字符串解码会触发异常。
• 使用容错编码查询全表，定位包含无效UTF-8字节的记录，直接修复对应数据。

5. 检查重试策略的影响 #

自定义的AmazonKeyspacesRetryPolicy可能在重试时重复使用异常连接，可调整重试策略逻辑，确保重试时使用新连接，或在驱动配置中开启重试时的连接刷新。

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