Uses of Class
org.apache.flink.statefun.sdk.kafka.KafkaIngressBuilder

Packages that use KafkaIngressBuilder

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

Uses of KafkaIngressBuilder in org.apache.flink.statefun.sdk.kafka

Methods in org.apache.flink.statefun.sdk.kafka that return KafkaIngressBuilder

Modifier and Type	Method and Description
KafkaIngressBuilder<T>	KafkaIngressBuilder.addTopics(java.util.List<java.lang.String> topics)
static <T> KafkaIngressBuilder<T>	KafkaIngressBuilder.forIdentifier(IngressIdentifier<T> id)
KafkaIngressBuilder<T>	KafkaIngressBuilder.withAutoResetPosition(KafkaIngressAutoResetPosition autoResetPosition)
KafkaIngressBuilder<T>	KafkaIngressBuilder.withConsumerGroupId(java.lang.String consumerGroupId)
KafkaIngressBuilder<T>	KafkaIngressBuilder.withDeserializer(java.lang.Class<? extends KafkaIngressDeserializer<T>> deserializerClass)
KafkaIngressBuilder<T>	KafkaIngressBuilder.withKafkaAddress(java.lang.String kafkaAddress)
KafkaIngressBuilder<T>	KafkaIngressBuilder.withProperties(java.util.Properties properties) A configuration property for the KafkaConsumer.
KafkaIngressBuilder<T>	KafkaIngressBuilder.withProperty(java.lang.String name, java.lang.String value) A configuration property for the KafkaProducer.
KafkaIngressBuilder<T>	KafkaIngressBuilder.withStartupPosition(KafkaIngressStartupPosition startupPosition) Configures the position that the ingress should start consuming from.
KafkaIngressBuilder<T>	KafkaIngressBuilder.withTopic(java.lang.String topic)

Methods in org.apache.flink.statefun.sdk.kafka with parameters of type KafkaIngressBuilder

Modifier and Type	Method and Description
static <T> void	KafkaIngressBuilderApiExtension.withDeserializer(KafkaIngressBuilder<T> kafkaIngressBuilder, KafkaIngressDeserializer<T> deserializer)