@Shuyi: Yes, a more advanced table example would be helpful anyway and
combining it with Kafka/Avro end-to-end would be even better.
@Will: I totally agree that the current connector ecosystem could be
improved. This is also on mid-term roadmap. Contributors that could help
here are very welco
Yes, I am also looking for examples for Kafka avro table examples in java and
command line. Also, Kafka avro table sink is still missing. In addition, once
we have Kafka topic, the API should read the schema directly from schema file
or schema registry. The way of current API supporting lacks of
Given the popularity of Flink SQL and Kafka as streaming source, I think we
can add some examples of using Kafka[XXX]TableSource in
flink-examples/flink-examples-table module. What do you guys think?
Cheers
Shuyi
On Mon, Jun 4, 2018 at 12:57 AM, Timo Walther wrote:
> Hi,
>
> as you can see in c
