programming

Flink 中的 Connectors

Fri Aug 7, 2020

连接器

Apache Kafka Connector

Kafka Consumer #

val properties = new Properties()
properties.setProperty("bootstrap.servers", "localhost:9092")
properties.setProperty("group.id", "test")
stream = env
    .addSource(new FlinkKafkaConsumer[String]("topic", new SimpleStringSchema(), properties))