Skip to content

Commit b95e9f3

Browse files
committed
Update author tag and events doc
1 parent e2626ed commit b95e9f3

File tree

2 files changed

+4
-0
lines changed

2 files changed

+4
-0
lines changed

spring-kafka-docs/src/main/antora/modules/ROOT/pages/kafka/events.adoc

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -102,6 +102,7 @@ In addition, the `ConsumerStoppedEvent` has the following additional property:
102102

103103
* `reason`:
104104
** `NORMAL` - the consumer stopped normally (container was stopped).
105+
** `ABNORMAL` - the consumer stopped abnormally (container was stopped abnormally).
105106
** `ERROR` - a `java.lang.Error` was thrown.
106107
** `FENCED` - the transactional producer was fenced and the `stopContainerWhenFenced` container property is `true`.
107108
** `AUTH` - an `AuthenticationException` or `AuthorizationException` was thrown and the `authExceptionRetryInterval` is not configured.

spring-kafka/src/main/java/org/springframework/kafka/event/ConsumerStoppedEvent.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,7 @@
2424
* to restart a container that was stopped because a transactional producer was fenced.
2525
*
2626
* @author Gary Russell
27+
* @author Lokesh Alamuri
2728
* @since 2.2
2829
*
2930
*/
@@ -45,6 +46,8 @@ public enum Reason {
4546

4647
/**
4748
* The consumer was stopped because the container was stopped abnormally.
49+
* @since 4.0
50+
*
4851
*/
4952
ABNORMAL,
5053

0 commit comments

Comments
 (0)