I’ve scoured the web looking for an example of using a Kafka source for a DataStream in python. Can someone finish this example?
env = StreamExecutionEnvironment.get_execution_environment() env.set_parallelism(1) ds = env.from_collection( KAFKA_SOURCE ) ... -- Robert Cullen 240-475-4490
