File tree Expand file tree Collapse file tree 2 files changed +13
-0
lines changed
spring-kafka/src/main/java/org/springframework/kafka/listener Expand file tree Collapse file tree 2 files changed +13
-0
lines changed Original file line number Diff line number Diff line change @@ -3159,17 +3159,23 @@ private OffsetAndMetadata createOffsetAndMetadata(long offset) {
3159
3159
3160
3160
private final class ConsumerAwareListenerMetadata implements ListenerMetadata {
3161
3161
3162
+ ConsumerAwareListenerMetadata () {
3163
+ }
3164
+
3162
3165
@ Override
3166
+ @ Nullable
3163
3167
public String getListenerId () {
3164
3168
return getBeanName ();
3165
3169
}
3166
3170
3167
3171
@ Override
3172
+ @ Nullable
3168
3173
public String getGroupId () {
3169
3174
return ListenerConsumer .this .consumerGroupId ;
3170
3175
}
3171
3176
3172
3177
@ Override
3178
+ @ Nullable
3173
3179
public byte [] getListenerInfo () {
3174
3180
return ListenerConsumer .this .listenerinfo ;
3175
3181
}
Original file line number Diff line number Diff line change 16
16
17
17
package org .springframework .kafka .listener ;
18
18
19
+ import org .springframework .lang .Nullable ;
20
+
19
21
/**
20
22
* Metadata associated to a {@link org.springframework.kafka.annotation.KafkaListener}.
21
23
*
22
24
* @author Francois Rosiere
25
+ * @author Gary Russell
23
26
* @since 2.8.5
24
27
* @see org.springframework.kafka.annotation.KafkaListener
25
28
*/
@@ -29,17 +32,21 @@ public interface ListenerMetadata {
29
32
* Return the listener id.
30
33
* @return the listener id.
31
34
*/
35
+ @ Nullable
32
36
String getListenerId ();
33
37
34
38
/**
35
39
* Return the group id.
36
40
* @return the group id.
37
41
*/
42
+ @ Nullable
38
43
String getGroupId ();
39
44
40
45
/**
41
46
* Return the listener info.
42
47
* @return the listener info.
43
48
*/
49
+ @ Nullable
44
50
byte [] getListenerInfo ();
51
+
45
52
}
You can’t perform that action at this time.
0 commit comments