Annotation Type PartitionOffset
- 
 @Target({}) @Retention(RUNTIME) public @interface PartitionOffsetUsed to add partition/initial offset information to aKafkaListener.- Author:
- Artem Bilan, Gary Russell
 
- 
- 
Required Element SummaryRequired Elements Modifier and Type Required Element Description java.lang.StringinitialOffsetThe initial offset of thepartition().java.lang.StringpartitionThe partition within the topic to listen on.
 - 
Optional Element SummaryOptional Elements Modifier and Type Optional Element Description java.lang.StringrelativeToCurrentBy default, positiveinitialOffset()is absolute, negative is relative to the current topic end.
 
- 
- 
- 
Element Detail- 
partitionjava.lang.String partition The partition within the topic to listen on. Property place holders and SpEL expressions are supported, which must resolve to Integer (or String that can be parsed as Integer). '*' indicates that the initial offset will be applied to all partitions in the encompassingTopicPartitionThe string can contain a comma-delimited list of partitions, or ranges of partitions (e.g.0-5, 7, 10-15, in which case, the offset will be applied to all of those partitions.- Returns:
- partition within the topic.
 
 
- 
 - 
- 
initialOffsetjava.lang.String initialOffset The initial offset of thepartition(). Property place holders and SpEL expressions are supported, which must resolve to Long (or String that can be parsed as Long).- Returns:
- initial offset.
 
 
- 
 - 
- 
relativeToCurrentjava.lang.String relativeToCurrent By default, positiveinitialOffset()is absolute, negative is relative to the current topic end. When this is 'true', the initial offset (positive or negative) is relative to the current consumer position.- Returns:
- whether or not the offset is relative to the current position.
- Since:
- 1.1
 - Default:
- "false"
 
 
- 
 
-