java.lang.AbstractMethodError: 
Method com/taskk$$Lambda$203.serialize(Ljava/lang/Object;Ljava/lang/Long;)
Lorg/apache/flink/kafka/shaded/org/apache/kafka/clients/producer/ProducerRecord; is abstract

问题原因是kafka版本过低再项目中导入kafka-client包，同时需要把flink-connector-kafka中的client包排除

        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-connector-kafka_2.11</artifactId>
            <version>1.13.6</version>
            <exclusions>
                <exclusion>
                    <groupId>org.apache.kafka</groupId>
                    <artifactId>kafka-clients</artifactId>
                </exclusion>
            </exclusions>
            <scope>provided</scope>
        </dependency>

添加kafka-client

  <dependency>
            <groupId>org.apache.kafka</groupId>
            <artifactId>kafka-clients</artifactId>
            <version>2.7.1</version>
        </dependency>