Package | Description |
---|---|
org.apache.flink.statefun.flink.io.kafka | |
org.apache.flink.statefun.sdk.kafka |
Class and Description |
---|
KafkaEgressSerializer |
KafkaIngressDeserializer
The deserialization schema describes how to turn the Kafka ConsumerRecords into data types that
are processed by the system.
|
Class and Description |
---|
KafkaEgressBuilder
A builder class for creating an
EgressSpec that writes data out to a Kafka cluster. |
KafkaEgressSerializer |
KafkaEgressSpec |
KafkaIngressAutoResetPosition
The auto offset reset position to use in case consumed offsets are invalid.
|
KafkaIngressBuilder
A builder for creating an
IngressSpec for consuming data from Apache Kafka. |
KafkaIngressDeserializer
The deserialization schema describes how to turn the Kafka ConsumerRecords into data types that
are processed by the system.
|
KafkaIngressSpec |
KafkaIngressStartupPosition
Position for the ingress to start consuming Kafka partitions.
|
KafkaIngressStartupPosition.DatePosition |
KafkaIngressStartupPosition.SpecificOffsetsPosition |
KafkaProducerSemantic |
KafkaTopicPartition
Representation of a Kafka partition.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.