@Target(value={})
@Retention(value=RUNTIME)
public @interface TopicPartition
KafkaListener.| Modifier and Type | Required Element and Description |
|---|---|
java.lang.String |
topic
The topic to listen on.
|
| Modifier and Type | Optional Element and Description |
|---|---|
java.lang.String[] |
partitions
The partitions within the topic.
|