Remove unused field from FailedRecordTracker

garyrussell · garyrussell · commit 37a1b5be2d51 · 2019-10-04T08:19:00.000-04:00
diff --git a/spring-kafka/src/main/java/org/springframework/kafka/listener/FailedRecordTracker.java b/spring-kafka/src/main/java/org/springframework/kafka/listener/FailedRecordTracker.java
@@ -46,8 +46,6 @@ class FailedRecordTracker {
 
 	private final BackOff backOff;
 
-	private final LogAccessor logger;
-
 	FailedRecordTracker(@Nullable BiConsumer<ConsumerRecord<?, ?>, Exception> recoverer, BackOff backOff,
 			LogAccessor logger) {
 
@@ -71,7 +69,6 @@ class FailedRecordTracker {
 		}
 		this.noRetries = backOff.start().nextBackOff() == BackOffExecution.STOP;
 		this.backOff = backOff;
-		this.logger = logger;
 	}
 
 	boolean skip(ConsumerRecord<?, ?> record, Exception exception) {

Original file line number	Diff line number	Diff line change
`@@ -46,8 +46,6 @@ class FailedRecordTracker {`
`46`	`46`
`47`	`47`	`private final BackOff backOff;`
`48`	`48`
`49`		`- private final LogAccessor logger;`
`50`		`-`
`51`	`49`	`FailedRecordTracker(@Nullable BiConsumer<ConsumerRecord<?, ?>, Exception> recoverer, BackOff backOff,`
`52`	`50`	`LogAccessor logger) {`
`53`	`51`
`@@ -71,7 +69,6 @@ class FailedRecordTracker {`
`71`	`69`	`}`
`72`	`70`	`this.noRetries = backOff.start().nextBackOff() == BackOffExecution.STOP;`
`73`	`71`	`this.backOff = backOff;`
`74`		`- this.logger = logger;`
`75`	`72`	`}`
`76`	`73`
`77`	`74`	`boolean skip(ConsumerRecord<?, ?> record, Exception exception) {`