jiegzhan opened a new issue #2883: URL: https://github.com/apache/hudi/issues/2883
Besides [flink-sql-client](https://hudi.apache.org/docs/flink-quick-start-guide.html#setup), does hudi support [flink DataStream API](https://ci.apache.org/projects/flink/flink-docs-stable/dev/connectors/kafka.html#kafka-consumer)? ``` // Read kafka topic with DataStream API val props = new Properties() props.put("bootstrap.servers", "localhost:9092") props.put("group.id", "flink-kafka-consumer") val consumer = new FlinkKafkaConsumer[String]("device_logs", new SimpleStringSchema(), props) val stream = senv.addSource(consumer) ``` Given DataStream[String] above ^^^, is there a way to publish it to hudi table? If yes, any scala/java code snippet? Thanks for your help. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected]
