Check for null in ErrHandlingDeserializer2.close()

lukyer · artembilan · commit 6de3747b5dcd · 2019-05-10T13:47:34.000-04:00
Wrap `this.delegate` into null check in the `ErrorHandlingDeserializer2.close()`
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
@@ -193,7 +193,9 @@ public T deserialize(String topic, Headers headers, byte[] data) {
 
 	@Override
 	public void close() {
-		this.delegate.close();
+		if (this.delegate != null) {
+			this.delegate.close();
+		}
 	}
 
 	private void deserializationException(Headers headers, byte[] data, Exception e) {

Original file line number	Diff line number	Diff line change
`@@ -193,7 +193,9 @@ public T deserialize(String topic, Headers headers, byte[] data) {`
`193`	`193`
`194`	`194`	`@Override`
`195`	`195`	`public void close() {`
`196`		`- this.delegate.close();`
	`196`	`+ if (this.delegate != null) {`
	`197`	`+ this.delegate.close();`
	`198`	`+ }`
`197`	`199`	`}`
`198`	`200`
`199`	`201`	`private void deserializationException(Headers headers, byte[] data, Exception e) {`