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

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
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.

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:

{}