Skip to content

Commit

Permalink
Update misleading contents in ConsumerPartitionPausedEvent and featur…
Browse files Browse the repository at this point in the history
…es.adoc
  • Loading branch information
bky373 committed Jun 2, 2024
1 parent abaa465 commit 90fbb05
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -221,7 +221,7 @@ This is to avoid creation of excessively large messages (due to the stack trace

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

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`.
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`.
See xref:retrytopic/retry-config.adoc#retry-topic-global-settings[Configuring Global Settings and Features] for more details.

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

`suffix` takes place before the general `dltTopicSuffix` in the custom DLT name.
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`.
Custom DLTs will be created following the same rules as stated in the xref:retrytopic/features.adoc#topics-autocreation[Topics AutoCreation].
Custom DLTs will be created following the same rules as stated in the xref:retrytopic/features.adoc#topics-autocreation[Topics AutoCreation].
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
/*
* Copyright 2018-2021 the original author or authors.
* Copyright 2018-2024 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
Expand All @@ -22,6 +22,7 @@
* An event published when a consumer partition is paused.
*
* @author Tomaz Fernandes
* @author Borahm Lee
* @since 2.7
*
*/
Expand All @@ -47,13 +48,13 @@ public ConsumerPartitionPausedEvent(Object source, Object container, TopicPartit
* Return the paused partition.
* @return the partition.
*/
public TopicPartition getPartitions() {
public TopicPartition getPartition() {
return this.partition;
}

@Override
public String toString() {
return "ConsumerPausedEvent [partitions=" + this.partition + "]";
return "ConsumerPartitionPausedEvent [partition=" + this.partition + "]";
}

}

0 comments on commit 90fbb05

Please sign in to comment.