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

Reply via email to