GH-1964: Fix removeDelegate

garyrussell · garyrussell · commit da04f48c0d73 · 2021-09-29T09:16:46.000-04:00
diff --git a/spring-kafka/src/main/java/org/springframework/kafka/support/serializer/DelegatingByTopicSerialization.java b/spring-kafka/src/main/java/org/springframework/kafka/support/serializer/DelegatingByTopicSerialization.java
@@ -257,8 +257,8 @@ public void addDelegate(Pattern pattern, T serializer) {
 	}
 
 	@Nullable
-	public T removeDelegate(String selector) {
-		return this.delegates.remove(selector);
+	public T removeDelegate(Pattern pattern) {
+		return this.delegates.remove(pattern);
 	}
 
 	/**

Original file line number	Diff line number	Diff line change
`@@ -257,8 +257,8 @@ public void addDelegate(Pattern pattern, T serializer) {`
`257`	`257`	`}`
`258`	`258`
`259`	`259`	`@Nullable`
`260`		`- public T removeDelegate(String selector) {`
`261`		`- return this.delegates.remove(selector);`
	`260`	`+ public T removeDelegate(Pattern pattern) {`
	`261`	`+ return this.delegates.remove(pattern);`
`262`	`262`	`}`
`263`	`263`
`264`	`264`	`/**`