Fix typo in the ErrorHandlingDeserializer2

artembilan · artembilan · commit 5fa86018624b · 2019-06-27T17:02:54.000-04:00
diff --git a/spring-kafka/src/main/java/org/springframework/kafka/support/serializer/ErrorHandlingDeserializer2.java b/spring-kafka/src/main/java/org/springframework/kafka/support/serializer/ErrorHandlingDeserializer2.java
@@ -211,7 +211,7 @@ public T deserialize(String topic, Headers headers, byte[] data) {
 	private T recoverFromSupplier(String topic, Headers headers, byte[] data, Exception exception) {
 		if (this.failedDeserializationFunction != null) {
 			FailedDeserializationInfo failedDeserializationInfo =
-					new FailedDeserializationInfo(topic, headers, data, this.isForKey, exception);
+					new FailedDeserializationInfo(topic, headers, data, this.isKey, exception);
 			return this.failedDeserializationFunction.apply(failedDeserializationInfo);
 		}
 		else {

Original file line number	Diff line number	Diff line change
`@@ -211,7 +211,7 @@ public T deserialize(String topic, Headers headers, byte[] data) {`
`211`	`211`	`private T recoverFromSupplier(String topic, Headers headers, byte[] data, Exception exception) {`
`212`	`212`	`if (this.failedDeserializationFunction != null) {`
`213`	`213`	`FailedDeserializationInfo failedDeserializationInfo =`
`214`		`- new FailedDeserializationInfo(topic, headers, data, this.isForKey, exception);`
	`214`	`+ new FailedDeserializationInfo(topic, headers, data, this.isKey, exception);`
`215`	`215`	`return this.failedDeserializationFunction.apply(failedDeserializationInfo);`
`216`	`216`	`}`
`217`	`217`	`else {`