public class KafkaIngressSpec<T> extends java.lang.Object implements IngressSpec<T>
Modifier and Type | Method and Description |
---|---|
KafkaIngressDeserializer<T> |
deserializer() |
IngressIdentifier<T> |
id()
Returns the unique identifier of the ingress.
|
java.util.Properties |
properties() |
KafkaIngressStartupPosition |
startupPosition() |
java.util.List<java.lang.String> |
topics() |
IngressType |
type()
Returns the type of the ingress.
|
public IngressIdentifier<T> id()
IngressSpec
id
in interface IngressSpec<T>
public IngressType type()
IngressSpec
type
in interface IngressSpec<T>
public java.util.Properties properties()
public java.util.List<java.lang.String> topics()
public KafkaIngressDeserializer<T> deserializer()
public KafkaIngressStartupPosition startupPosition()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.