背景： 在ods->dwd时，由于需要同时对pojo类型的kafka多流（消费多个topic）数据消费时需要操作类似的反序列化，所以需要先将此操泛型化。加入class这个参数。即将操作对象泛型化。 原来的分topic反序列化： KafkaSource<OrderInfo>orderInfoKafkaSource=KafkaSource.<OrderInfo>builder() .setBootstrapServers(Constants.KAFKA_BROKER) .setTopics(orderInfoSourceTopic) .setGroupId(grou...