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 @@ -3149,17 +3149,23 @@ private OffsetAndMetadata createOffsetAndMetadata(long offset) {
3149
3149
3150
3150
private final class ConsumerAwareListenerMetadata implements ListenerMetadata {
3151
3151
3152
+ ConsumerAwareListenerMetadata () {
3153
+ }
3154
+
3152
3155
@ Override
3156
+ @ Nullable
3153
3157
public String getListenerId () {
3154
3158
return getBeanName ();
3155
3159
}
3156
3160
3157
3161
@ Override
3162
+ @ Nullable
3158
3163
public String getGroupId () {
3159
3164
return ListenerConsumer .this .consumerGroupId ;
3160
3165
}
3161
3166
3162
3167
@ Override
3168
+ @ Nullable
3163
3169
public byte [] getListenerInfo () {
3164
3170
return ListenerConsumer .this .listenerinfo ;
3165
3171
}
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