From 63a4acda1b1489a68f55674f3680f07ac85edf8a Mon Sep 17 00:00:00 2001 From: Gary Russell Date: Wed, 13 Feb 2019 16:28:13 -0500 Subject: [PATCH] Fix test for SK 2.2.4 Override deserializer getters in test consumer factory because the defaults incorrectly throw an `UnsupportedOperationException`. See https://github.com/spring-projects/spring-kafka/pull/963 --- .../stream/binder/kafka/KafkaBinderUnitTests.java | 13 ++++++++++++- 1 file changed, 12 insertions(+), 1 deletion(-) diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderUnitTests.java b/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderUnitTests.java index b5f95231e..17a0f2b72 100644 --- a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderUnitTests.java +++ b/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderUnitTests.java @@ -1,5 +1,5 @@ /* - * Copyright 2017-2018 the original author or authors. + * Copyright 2017-2019 the original author or authors. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -35,6 +35,7 @@ import org.apache.kafka.clients.consumer.ConsumerRecords; import org.apache.kafka.clients.producer.ProducerConfig; import org.apache.kafka.common.PartitionInfo; import org.apache.kafka.common.TopicPartition; +import org.apache.kafka.common.serialization.Deserializer; import org.junit.Test; import org.mockito.ArgumentCaptor; @@ -263,6 +264,16 @@ public class KafkaBinderUnitTests { return props; } + @Override + public Deserializer getKeyDeserializer() { + return null; + } + + @Override + public Deserializer getValueDeserializer() { + return null; + } + }; }