org.springframework.kafka.annotation

Annotation Type TopicPartition

@Target(value={})
 @Retention(value=RUNTIME)
public @interface TopicPartition

Used to add topic/partition information to a KafkaListener.

Author:

Gary Russell, Artem Bilan

Required Element Summary

Required Elements

Modifier and Type	Required Element and Description
java.lang.String	topic The topic to listen on.

Optional Element Summary

Optional Elements

Modifier and Type	Optional Element and Description
PartitionOffset[]	partitionOffsets The partitions with initial offsets within the topic.
java.lang.String[]	partitions The partitions within the topic.

Element Detail

topic

public abstract java.lang.String topic

The topic to listen on.

Returns:

the topic to listen on. Property place holders and SpEL expressions are supported, which must resolve to a String.

partitions

public abstract java.lang.String[] partitions

The partitions within the topic. Partitions specified here can't be duplicated in partitionOffsets().

Returns:

the partitions within the topic. Property place holders and SpEL expressions are supported, which must resolve to Integers (or Strings that can be parsed as Integers).

Default:

{}

partitionOffsets

public abstract PartitionOffset[] partitionOffsets

The partitions with initial offsets within the topic. Partitions specified here can't be duplicated in the partitions().

Returns:

the PartitionOffset array.

Default:

{}