flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Rong Rong <walter...@gmail.com>
Subject Re: Want to write Kafka Sink to SQL Client by Flink-1.5
Date Thu, 12 Jul 2018 00:45:39 GMT
Hi Shivam,
Thank you for interested in contributing to Kafka Sink for SQL client.
Could you share your plan for implementation. I have some questions as
there might have been some overlap with current implementations.

On a higher level,
1. Are you using some type of metadata store to host topic schemas (Kafka
can essentially be schema-less), it might be great to take a look at the
TableSource/SinkFactory [1][2]
2. There's already a KafkaTableSource and KafkaTableSink available, I am
assuming you are trying to contribute to the configuration in SQL Client to
make it easier to interact with a Kafka table?

Thanks,
Rong

[1]: https://issues.apache.org/jira/browse/FLINK-8839
[2]: https://issues.apache.org/jira/browse/FLINK-8866

On Tue, Jul 10, 2018 at 3:28 AM Shivam Sharma <28shivamsharma@gmail.com>
wrote:

> Hi All,
>
> We want to write Kafka Sink functionality for Flink(1.5) SQL Client. We
> have read the code and chalk out a rough plan for implementation.
>
> Any guidance for this implementation will be very helpful.
>
> Thanks
> --
> Shivam Sharma
> Data Engineer @ Goibibo
> Indian Institute Of Information Technology, Design and Manufacturing
> Jabalpur
> Mobile No- (+91) 8882114744
> Email:- 28shivamsharma@gmail.com
> LinkedIn:-*https://www.linkedin.com/in/28shivamsharma
> <https://www.linkedin.com/in/28shivamsharma>*
>

Mime
View raw message