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