@Target(value={})
@Retention(value=RUNTIME)
public @interface PartitionOffset
KafkaListener.| Modifier and Type | Required Element and Description |
|---|---|
java.lang.String |
initialOffset
The initial offset of the
partition(). |
java.lang.String |
partition
The partition within the topic to listen on.
|
public abstract java.lang.String partition
public abstract java.lang.String initialOffset
partition().
Property place holders and SpEL expressions are supported,
which must resolve to Long (or String that can be parsed as Long).