Skip to content

Commit 604ecce

Browse files
committed
KafkaListener javaodc polishing
1 parent 5bdd7f8 commit 604ecce

File tree

2 files changed

+4
-2
lines changed

2 files changed

+4
-2
lines changed

spring-kafka/src/main/java/org/springframework/kafka/annotation/KafkaListener.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -113,6 +113,7 @@
113113
* The topics for this listener.
114114
* The entries can be 'topic name', 'property-placeholder keys' or 'expressions'.
115115
* An expression must be resolved to the topic name.
116+
* This uses group management and Kafka will assign partitions to group members.
116117
* <p>
117118
* Mutually exclusive with {@link #topicPattern()} and {@link #topicPartitions()}.
118119
* @return the topic names or expressions (SpEL) to listen to.
@@ -126,6 +127,7 @@
126127
* dynamically assigned partitions. The pattern matching will be performed
127128
* periodically against topics existing at the time of check. An expression must
128129
* be resolved to the topic pattern (String or Pattern result types are supported).
130+
* This uses group management and Kafka will assign partitions to group members.
129131
* <p>
130132
* Mutually exclusive with {@link #topics()} and {@link #topicPartitions()}.
131133
* @return the topic pattern or expression (SpEL).
@@ -134,7 +136,8 @@
134136
String topicPattern() default "";
135137

136138
/**
137-
* The topicPartitions for this listener.
139+
* The topicPartitions for this listener when using manual topic/partition
140+
* assignment.
138141
* <p>
139142
* Mutually exclusive with {@link #topicPattern()} and {@link #topics()}.
140143
* @return the topic names or expressions (SpEL) to listen to.

spring-kafka/src/test/java/org/springframework/kafka/listener/ManualNackRecordTests.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,6 @@ public class ManualNackRecordTests {
7373
@SuppressWarnings("rawtypes")
7474
@Autowired
7575
private Consumer consumer;
76-
7776
@Autowired
7877
private Config config;
7978

0 commit comments

Comments
 (0)