Skip to content

Commit 1dde70a

Browse files
authored
Deprecate DestinationTopicPropertiesFactory CTORs
So they can be removed in 3.1, along with `FixedDelayStrategy`.
1 parent 30ee20d commit 1dde70a

File tree

1 file changed

+74
-12
lines changed

1 file changed

+74
-12
lines changed

spring-kafka/src/main/java/org/springframework/kafka/retrytopic/DestinationTopicPropertiesFactory.java

Lines changed: 74 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -71,6 +71,80 @@ public class DestinationTopicPropertiesFactory {
7171
@Nullable
7272
private Boolean autoStartDltHandler;
7373

74+
/**
75+
* Construct an instance with the provided properties.
76+
* @param retryTopicSuffix the suffix.
77+
* @param dltSuffix the dlt suffix.
78+
* @param backOffValues the back off values.
79+
* @param exceptionClassifier the exception classifier.
80+
* @param numPartitions the number of partitions.
81+
* @param kafkaOperations the operations.
82+
* @param dltStrategy the dlt strategy.
83+
* @param topicSuffixingStrategy the topic suffixing strategy.
84+
* @param sameIntervalTopicReuseStrategy the same interval reuse strategy.
85+
* @param timeout the timeout.
86+
* @since 3.0.12
87+
*/
88+
@SuppressWarnings(DEPRECATION)
89+
public DestinationTopicPropertiesFactory(String retryTopicSuffix, String dltSuffix, List<Long> backOffValues,
90+
BinaryExceptionClassifier exceptionClassifier,
91+
int numPartitions, KafkaOperations<?, ?> kafkaOperations,
92+
DltStrategy dltStrategy,
93+
TopicSuffixingStrategy topicSuffixingStrategy,
94+
SameIntervalTopicReuseStrategy sameIntervalTopicReuseStrategy,
95+
long timeout) {
96+
97+
this(retryTopicSuffix, dltSuffix, backOffValues, exceptionClassifier, numPartitions, kafkaOperations,
98+
FixedDelayStrategy.SINGLE_TOPIC, dltStrategy, topicSuffixingStrategy, sameIntervalTopicReuseStrategy,
99+
timeout);
100+
}
101+
102+
/**
103+
* Construct an instance with the provided properties.
104+
* @param retryTopicSuffix the suffix.
105+
* @param dltSuffix the dlt suffix.
106+
* @param backOffValues the back off values.
107+
* @param exceptionClassifier the exception classifier.
108+
* @param numPartitions the number of partitions.
109+
* @param kafkaOperations the operations.
110+
* @param fixedDelayStrategy the fixed delay strategy.
111+
* @param dltStrategy the dlt strategy.
112+
* @param topicSuffixingStrategy the topic suffixing strategy.
113+
* @param timeout the timeout.
114+
* @deprecated in favor of
115+
* {@link #DestinationTopicPropertiesFactory(String, String, List, BinaryExceptionClassifier, int, KafkaOperations, DltStrategy, TopicSuffixingStrategy, SameIntervalTopicReuseStrategy, long)}
116+
*/
117+
@Deprecated
118+
@SuppressWarnings(DEPRECATION)
119+
public DestinationTopicPropertiesFactory(String retryTopicSuffix, String dltSuffix, List<Long> backOffValues,
120+
BinaryExceptionClassifier exceptionClassifier,
121+
int numPartitions, KafkaOperations<?, ?> kafkaOperations,
122+
FixedDelayStrategy fixedDelayStrategy,
123+
DltStrategy dltStrategy,
124+
TopicSuffixingStrategy topicSuffixingStrategy,
125+
long timeout) {
126+
this(retryTopicSuffix, dltSuffix, backOffValues, exceptionClassifier, numPartitions, kafkaOperations,
127+
fixedDelayStrategy, dltStrategy, topicSuffixingStrategy, SameIntervalTopicReuseStrategy.MULTIPLE_TOPICS,
128+
timeout);
129+
}
130+
131+
/**
132+
* Construct an instance with the provided properties.
133+
* @param retryTopicSuffix the suffix.
134+
* @param dltSuffix the dlt suffix.
135+
* @param backOffValues the back off values.
136+
* @param exceptionClassifier the exception classifier.
137+
* @param numPartitions the number of partitions.
138+
* @param kafkaOperations the operations.
139+
* @param fixedDelayStrategy the fixed delay strategy.
140+
* @param dltStrategy the dlt strategy.
141+
* @param topicSuffixingStrategy the topic suffixing strategy.
142+
* @param sameIntervalTopicReuseStrategy the same interval reuse strategy.
143+
* @param timeout the timeout.
144+
* @deprecated in favor of
145+
* {@link #DestinationTopicPropertiesFactory(String, String, List, BinaryExceptionClassifier, int, KafkaOperations, DltStrategy, TopicSuffixingStrategy, SameIntervalTopicReuseStrategy, long)}
146+
*/
147+
@Deprecated
74148
@SuppressWarnings(DEPRECATION)
75149
public DestinationTopicPropertiesFactory(String retryTopicSuffix, String dltSuffix, List<Long> backOffValues,
76150
BinaryExceptionClassifier exceptionClassifier,
@@ -95,18 +169,6 @@ public DestinationTopicPropertiesFactory(String retryTopicSuffix, String dltSuff
95169
this.maxAttempts = this.backOffValues.size() + 1;
96170
}
97171

98-
@SuppressWarnings(DEPRECATION)
99-
public DestinationTopicPropertiesFactory(String retryTopicSuffix, String dltSuffix, List<Long> backOffValues,
100-
BinaryExceptionClassifier exceptionClassifier,
101-
int numPartitions, KafkaOperations<?, ?> kafkaOperations,
102-
FixedDelayStrategy fixedDelayStrategy,
103-
DltStrategy dltStrategy,
104-
TopicSuffixingStrategy topicSuffixingStrategy,
105-
long timeout) {
106-
this(retryTopicSuffix, dltSuffix, backOffValues, exceptionClassifier, numPartitions, kafkaOperations,
107-
fixedDelayStrategy, dltStrategy, topicSuffixingStrategy, SameIntervalTopicReuseStrategy.MULTIPLE_TOPICS,
108-
timeout);
109-
}
110172
/**
111173
* Set to false to not start the DLT handler.
112174
* @param autoStart false to not start.

0 commit comments

Comments
 (0)