Skip to content

Commit 2fd4ddb

Browse files
committed
GH-990: DARP: Restore and deprecate old property
See #990 Property rename was not back-ported.
1 parent 7a78cd1 commit 2fd4ddb

File tree

1 file changed

+15
-1
lines changed

1 file changed

+15
-1
lines changed

spring-kafka/src/main/java/org/springframework/kafka/listener/DefaultAfterRollbackProcessor.java

Lines changed: 15 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -161,7 +161,7 @@ public boolean isProcessInTransaction() {
161161
* if a record is skipped and recovered, we will send its offset to the transaction.
162162
* Requires a {@link KafkaTemplate}.
163163
* @param commitRecovered true to process in a transaction.
164-
* @since 2.2.5
164+
* @since 2.3
165165
* @see #isProcessInTransaction()
166166
* @see #process(List, Consumer, Exception, boolean)
167167
* @see #setKafkaTemplate(KafkaTemplate)
@@ -171,6 +171,20 @@ public void setCommitRecovered(boolean commitRecovered) { // NOSONAR enhanced ja
171171
super.setCommitRecovered(commitRecovered);
172172
}
173173

174+
/**
175+
* Set to true to run the {@link #process(List, Consumer, Exception, boolean)}
176+
* method in a transaction. Requires a {@link KafkaTemplate}.
177+
* @param processInTransaction true to process in a transaction.
178+
* @since 2.2.5
179+
* @see #process(List, Consumer, Exception, boolean)
180+
* @see #setKafkaTemplate(KafkaTemplate)
181+
* @deprecated in favor of {@link #setCommitRecovered(boolean)}.
182+
*/
183+
@Deprecated
184+
public void setProcessInTransaction(boolean processInTransaction) {
185+
setCommitRecovered(processInTransaction);
186+
}
187+
174188
/**
175189
* Set a {@link KafkaTemplate} to use to send the offset of a recovered record
176190
* to a transaction.

0 commit comments

Comments
 (0)