I think the FlinkKakfaConsumer010 you're talking about is the old source api. You should use only KafkaSource now, as they use the new source infrastructure.
On Tue, Feb 1, 2022 at 9:02 AM HG <hanspeter.sl...@gmail.com> wrote: > Hello Francesco > Perhaps I copied the wrong link of 1.2. > But there is also > https://nightlies.apache.org/flink/flink-docs-release-1.4/api/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer010.html > > It seems there are 2 ways to use Kafka > > KafkaSource<String> source = KafkaSource.<String>builder() > .setBootstrapServers(brokers) > .setTopics("input-topic") > .setGroupId("my-group") > .setStartingOffsets(OffsetsInitializer.earliest()) > .setValueOnlyDeserializer(new SimpleStringSchema()) > .build(); > > And like this: > > Properties kafkaProperties = new Properties(); > kafkaProperties.put("bootstrap.servers",kafkaBootstrapServers); > kafkaProperties.put("group.id",kafkaGroupID); > kafkaProperties.put("auto.offset.reset",kafkaAutoOffsetReset); > FlinkKafkaConsumer010<String> kafkaConsumer = new > FlinkKafkaConsumer010<>(kafkaTopic, new SimpleStringSchema(), > kafkaProperties); > kafkaConsumer.setCommitOffsetsOnCheckpoints(true); > > > There is even a FlinkKafkaConsumer011 > > Which one is preferable ? Or have they different use cases? > > Regards Hans > > > Op di 1 feb. 2022 om 08:55 schreef Francesco Guardiani < > france...@ververica.com>: > >> The latter link you posted refers to a very old flink release. You shold >> use the first link, which refers to latest release >> >> FG >> >> On Tue, Feb 1, 2022 at 8:20 AM HG <hanspeter.sl...@gmail.com> wrote: >> >>> Hello all >>> >>> I am confused. >>> What is the difference between KafkaSource as defined in : >>> https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/connectors/datastream/kafka/ >>> and FlinkKafkaConsumer010 as defined in >>> https://nightlies.apache.org/flink/flink-docs-release- >>> 1.2/api/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer010.html >>> <https://nightlies.apache.org/flink/flink-docs-release-1.2/api/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer010.html> >>> >>> When should I use which? >>> >>> Regards Hans >>> >>
