Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/4915#discussion_r147689963 --- Diff: flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java --- @@ -483,11 +478,6 @@ public void setLogFailuresOnly(boolean logFailuresOnly) { */ @Override public void open(Configuration configuration) throws Exception { - if (semantic != Semantic.NONE && !((StreamingRuntimeContext) this.getRuntimeContext()).isCheckpointingEnabled()) { --- End diff -- ok
---