rakulang, dartlang, nimlang, golang, rustlang, lang lang no see

Flink 中的 Connectors

焉知非鱼

连接器

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))