File tree 2 files changed +6
-7
lines changed
spring-kafka/src/main/java/org/springframework/kafka/support
2 files changed +6
-7
lines changed Original file line number Diff line number Diff line change @@ -67,15 +67,15 @@ ext {
67
67
kafkaVersion = ' 3.5.1'
68
68
log4jVersion = ' 2.20.0'
69
69
micrometerDocsVersion = " 1.0.2"
70
- micrometerVersion = ' 1.12.0-SNAPSHOT '
71
- micrometerTracingVersion = ' 1.2.0-SNAPSHOT '
70
+ micrometerVersion = ' 1.12.0-M3 '
71
+ micrometerTracingVersion = ' 1.2.0-M3 '
72
72
mockitoVersion = ' 5.5.0'
73
- reactorVersion = ' 2023.0.0-M2 '
73
+ reactorVersion = ' 2023.0.0-M3 '
74
74
scalaVersion = ' 2.13'
75
75
springBootVersion = ' 3.0.9' // docs module
76
- springDataVersion = ' 2023.1.0-SNAPSHOT '
77
- springRetryVersion = ' 2.0.2 '
78
- springVersion = ' 6.1.0-SNAPSHOT '
76
+ springDataVersion = ' 2023.1.0-M3 '
77
+ springRetryVersion = ' 2.0.3 '
78
+ springVersion = ' 6.1.0-M5 '
79
79
zookeeperVersion = ' 3.6.4'
80
80
81
81
idPrefix = ' kafka'
Original file line number Diff line number Diff line change @@ -48,7 +48,6 @@ public KafkaMessageHeaderAccessor(Message<?> message) {
48
48
* @throws IllegalStateException if the header is not present.
49
49
* @see org.springframework.kafka.listener.ContainerProperties#setDeliveryAttemptHeader(boolean)
50
50
*/
51
- @ Nullable
52
51
public int getBlockingRetryDeliveryAttempt () {
53
52
Assert .state (getHeader (KafkaHeaders .DELIVERY_ATTEMPT ) != null ,
54
53
"Blocking delivery attempt header not present, "
You can’t perform that action at this time.
0 commit comments