I could not find any working example of how to use the Kafka connector together with Apache Flink Python API.
Could anyone provide a working example?
Asked
Active
Viewed 854 times
2
-
Maybe http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Using-a-custom-DeserializationSchema-with-Kafka-and-Python-td22094.html#a22123 will help. – David Anderson Jan 04 '19 at 21:26
-
I followed these steps and got it running https://stackoverflow.com/questions/52744277/apache-flink-kafka-connector-in-python-streaming-api-cannot-load-user-class – Miriah Peterson Feb 08 '19 at 18:51