结合 Flink 学习装饰者模式

@Internalpublic class KafkaDeserializationSchemaWrapper<T> implements KafkaDeserializationSchema<T> {
	private static final long serialVersionUID = 2651665280744549932L;
	private final DeserializationSchema<T> deserializationSchema;
	public KafkaDeserializationSchemaWrapper(DeserializationSchema<T> deserializationSchema) {		this.deserializationSchema = deserializationSchema;	}
	@Override	public T deserialize(ConsumerRecord<byte[], byte[]> record) throws Exception {		return deserializationSchema.deserialize(record.value());	}
	@Override	public boolean isEndOfStream(T nextElement) {		return deserializationSchema.isEndOfStream(nextElement);	}
	@Override	public TypeInformation<T> getProducedType() {		return deserializationSchema.getProducedType();	}}

public FlinkKafkaConsumer(Pattern subscriptionPattern, DeserializationSchema<T> valueDeserializer, Properties props) {		this(null, subscriptionPattern, new KafkaDeserializationSchemaWrapper<>(valueDeserializer), props);	}