Class | Description |
---|---|
GenericKafkaEgressSerializer |
A
KafkaEgressSerializer used solely by sinks provided by the GenericKafkaSinkProvider . |
KafkaEgressTypes | |
KafkaFlinkIoModule | |
KafkaSinkProvider | |
KafkaSourceProvider | |
ProtobufKafkaIngressTypes | |
RoutableProtobufKafkaIngressDeserializer |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.