Skip to content

Commit 634c540

Browse files
committed
Update ConsumerPartitionPausedEvent and features.adoc
1 parent abaa465 commit 634c540

File tree

2 files changed

+6
-5
lines changed

2 files changed

+6
-5
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -221,7 +221,7 @@ This is to avoid creation of excessively large messages (due to the stack trace
221221

222222
See xref:kafka/annotation-error-handling.adoc#dlpr-headers[Managing Dead Letter Record Headers] for more information.
223223

224-
To reconfigure the framework to use different settings for these properties, configure a `DeadLetterPublishingRecovererer` customizer by overriding the `configureCustomizers` method in a `@Configuration` class that extends `RetryTopicConfigurationSupport`.
224+
To reconfigure the framework to use different settings for these properties, configure a `DeadLetterPublishingRecoverer` customizer by overriding the `configureCustomizers` method in a `@Configuration` class that extends `RetryTopicConfigurationSupport`.
225225
See xref:retrytopic/retry-config.adoc#retry-topic-global-settings[Configuring Global Settings and Features] for more details.
226226

227227
[source, java]
@@ -298,4 +298,4 @@ public RetryTopicConfiguration myRetryTopic(KafkaTemplate<String, MyPojo> templa
298298

299299
`suffix` takes place before the general `dltTopicSuffix` in the custom DLT name.
300300
Considering presented examples, the message, which caused the `DeserializationException` will be routed to the `my-annotated-topic-deserialization-dlt` instead of the `my-annotated-topic-dlt`.
301-
Custom DLTs will be created following the same rules as stated in the xref:retrytopic/features.adoc#topics-autocreation[Topics AutoCreation].
301+
Custom DLTs will be created following the same rules as stated in the xref:retrytopic/features.adoc#topics-autocreation[Topics AutoCreation].

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

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright 2018-2021 the original author or authors.
2+
* Copyright 2018-2024 the original author or authors.
33
*
44
* Licensed under the Apache License, Version 2.0 (the "License");
55
* you may not use this file except in compliance with the License.
@@ -22,6 +22,7 @@
2222
* An event published when a consumer partition is paused.
2323
*
2424
* @author Tomaz Fernandes
25+
* @author Borahm Lee
2526
* @since 2.7
2627
*
2728
*/
@@ -47,13 +48,13 @@ public ConsumerPartitionPausedEvent(Object source, Object container, TopicPartit
4748
* Return the paused partition.
4849
* @return the partition.
4950
*/
50-
public TopicPartition getPartitions() {
51+
public TopicPartition getPartition() {
5152
return this.partition;
5253
}
5354

5455
@Override
5556
public String toString() {
56-
return "ConsumerPausedEvent [partitions=" + this.partition + "]";
57+
return "ConsumerPartitionPausedEvent [partition=" + this.partition + "]";
5758
}
5859

5960
}

0 commit comments

Comments
 (0)