我的 FlinkKafkaProducer011 需要的参数比预期的要少

Question

我在使用 FlinkKafkaConnector 时遇到了问题。

虽然我已经导入了org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011，但我得到了以下错误。

Too many arguments for constructor FlinkKafkaProducer011

根据this site，参数是正确的。但是，我的 IntelliJ 显示了这个定义。

public FlinkKafkaProducer011() {
}

有人知道怎么解决吗？

更新

这是 IDE 定义。

public class FlinkKafkaProducer011 {
    public FlinkKafkaProducer011() {
    }

    public static class NextTransactionalIdHint extends org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer.NextTransactionalIdHint {
        public NextTransactionalIdHint() {
        }
    }

    public static class TransactionStateSerializer {
        public TransactionStateSerializer() {
        }

        public static final class TransactionStateSerializerSnapshot extends SimpleTypeSerializerSnapshot<KafkaTransactionState> {
            public TransactionStateSerializerSnapshot() {
                super(org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer.TransactionStateSerializer::new);
            }
        }
    }

    public static class ContextStateSerializer {
        public ContextStateSerializer() {
        }

        public static final class ContextStateSerializerSnapshot extends SimpleTypeSerializerSnapshot<KafkaTransactionContext> {
            public ContextStateSerializerSnapshot() {
                super(org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer.ContextStateSerializer::new);
            }
        }
    }

    public static class NextTransactionalIdHintSerializer {
        public NextTransactionalIdHintSerializer() {
        }

        public static final class NextTransactionalIdHintSerializerSnapshot extends SimpleTypeSerializerSnapshot<org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer.NextTransactionalIdHint> {
            public NextTransactionalIdHintSerializerSnapshot() {
                super(org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer.NextTransactionalIdHintSerializer::new);
            }
        }
    }
}

Answer 1

能否请您指定您使用的flink-connector-kafka 版本？

据我所知，您使用的org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011 只是flink-connector-kafka_2.11 jar 中的一个兼容类，正确的生产者是org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer。

据我了解，javadoc https://ci.apache.org/projects/flink/flink-docs-release-1.4/api/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.html 与来自flink-connector-kafka-0.11_2.11 工件的org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011 生产者相关。

所以，我建议要么切换到org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer，要么将依赖项更改为flink-connector-kafka-0.11_2.11 jar。