Kafka的JsonDeserializer不支持多种日期格式的解析。

可以自定义一个JsonDeserializer，使用Jackson库来处理日期格式。具体示例如下：

public class CustomJsonDeserializer<T> extends JsonDeserializer<T> {
 
    private final ObjectMapper mapper = new ObjectMapper();
 
    private final List<String> dateFormats;
 
    public CustomJsonDeserializer(List<String> dateFormats) {
        this.dateFormats = dateFormats;
    }
 
    @Override
    public T deserialize(JsonParser jp, DeserializationContext ctxt)
            throws IOException, JsonProcessingException {
 
        JsonNode node = jp.getCodec().readTree(jp);
        if (node.isObject()) {
            ObjectNode objectNode = (ObjectNode) node;
            for (Iterator<Map.Entry<String, JsonNode>> it = objectNode.fields(); it.hasNext(); ) {
                Map.Entry<String, JsonNode> entry = it.next();
                if (entry.getValue().isTextual()) {
                    String value = entry.getValue().asText();
                    for (String dateFormat : dateFormats) {
                        try {
                            Date date = new SimpleDateFormat(dateFormat).parse(value);
                            objectNode.put(entry.getKey(), date.getTime());
                            break;
                        } catch (ParseException e) {
                            // keep trying other formats
                        }
                    }
                }
            }
        }
        return mapper.convertValue(node, new TypeReference<T>() {});
    }
}

使用方法：

List<String> dateFormats = Arrays.asList("yyyy-MM-dd HH:mm:ss", "yyyy-MM-dd'T'HH:mm:ss.SSSZ");
JsonDeserializer<MyObject> deserializer = new CustomJsonDeserializer<>(dateFormats);
ObjectMapper mapper = new ObjectMapper();
SimpleModule module = new SimpleModule("MyModule", Version.unknownVersion());
module.addDeserializer(MyObject.class, deserializer);
mapper.registerModule(module);

这样，当反序列化的JSON字符串中出现日期字符串时，会按照指定的日期格式进行解析，最终将其转换为long类型的时间戳。