KafkaConnect-由于意外的对象类型java.lang.Double，没有转换器存在

该问题通常是因为 Kafka Connect 的 Value 转换器不能将消息的值转换为所需的目标类型而导致的。解决方法是添加自定义转换器，将未支持的对象类型转换为目标类型。以下是示例代码：

// 自定义转换器类 public class CustomConverter implements Converter {

@Override public void configure(Map<String, ?> configs, boolean isKey) { // 进行配置 }

@Override public byte[] fromConnectData(String topic, Schema schema, Object value) { // 进行转换 if (value instanceof Double) { Double doubleValue = (Double) value; Long longValue = doubleValue.longValue(); return longValue.toString().getBytes(); } return new byte[0]; }

@Override public SchemaAndValue toConnectData(String topic, byte[] value) { // 进行反向转换 Long longValue = Long.parseLong(new String(value)); return new SchemaAndValue(Schema.INT64_SCHEMA, longValue); } }

// 将转换器配置为值的转换器 ValueConverter converter = new CustomConverter(); Map<String, String> config = new HashMap<>(); config.put("value.converter", "CustomConverter"); converter.configure(config, false);