public class KafkaSourceProvider extends java.lang.Object implements SourceProvider
Constructor and Description |
---|
KafkaSourceProvider() |
Modifier and Type | Method and Description |
---|---|
<T> org.apache.flink.streaming.api.functions.source.SourceFunction<T> |
forSpec(IngressSpec<T> ingressSpec) |
public <T> org.apache.flink.streaming.api.functions.source.SourceFunction<T> forSpec(IngressSpec<T> ingressSpec)
forSpec
in interface SourceProvider
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.