Package org.apache.flink.statefun.sdk.kafka

Interface Summary

Interface	Description
KafkaEgressSerializer<OutT>	A KafkaEgressSerializer defines how to serialize values of type T into ProducerRecords.
KafkaIngressDeserializer<T>	The deserialization schema describes how to turn the Kafka ConsumerRecords into data types that are processed by the system.

Class Summary

Class	Description
Constants
KafkaEgressBuilder<OutT>	A builder class for creating an EgressSpec that writes data out to a Kafka cluster.
KafkaEgressSpec<OutT>
KafkaIngressBuilder<T>	A builder for creating an IngressSpec for consuming data from Apache Kafka.
KafkaIngressBuilderApiExtension
KafkaIngressSpec<T>
KafkaIngressStartupPosition	Position for the ingress to start consuming Kafka partitions.
KafkaIngressStartupPosition.DatePosition
KafkaIngressStartupPosition.EarliestPosition
KafkaIngressStartupPosition.GroupOffsetsPosition
KafkaIngressStartupPosition.LatestPosition
KafkaIngressStartupPosition.SpecificOffsetsPosition
KafkaTopicPartition	Representation of a Kafka partition.

Enum Summary

Enum	Description
KafkaIngressAutoResetPosition	The auto offset reset position to use in case consumed offsets are invalid.
KafkaProducerSemantic