Generics cleanup in test

* Cleaning up unnecessary generics in `RecoveringDeserializationExceptionHandlerTests`

Author: sobychacko

spring-kafka/src/test/java/org/springframework/kafka/streams/RecoveringDeserializationExceptionHandlerTests.java

@@ -92,9 +92,9 @@ void viaStringProperty() {
 				Recoverer.class.getName());
 		handler.configure(configs);
 		assertThat(KafkaTestUtils.getPropertyValue(handler, "recoverer")).isInstanceOf(Recoverer.class);
-		assertThat(handler.handle(null, new ConsumerRecord<byte[], byte[]>("foo", 0, 0, null, null),
+		assertThat(handler.handle(null, new ConsumerRecord<>("foo", 0, 0, null, null),
 				new IllegalArgumentException())).isEqualTo(DeserializationHandlerResponse.CONTINUE);
-		assertThat(handler.handle(null, new ConsumerRecord<byte[], byte[]>("foo", 0, 0, null, null),
+		assertThat(handler.handle(null, new ConsumerRecord<>("foo", 0, 0, null, null),
 				new IllegalStateException())).isEqualTo(DeserializationHandlerResponse.FAIL);
 	}
 
@@ -105,30 +105,30 @@ void viaClassProperty() {
 		configs.put(RecoveringDeserializationExceptionHandler.KSTREAM_DESERIALIZATION_RECOVERER, Recoverer.class);
 		handler.configure(configs);
 		assertThat(KafkaTestUtils.getPropertyValue(handler, "recoverer")).isInstanceOf(Recoverer.class);
-		assertThat(handler.handle(null, new ConsumerRecord<byte[], byte[]>("foo", 0, 0, null, null),
+		assertThat(handler.handle(null, new ConsumerRecord<>("foo", 0, 0, null, null),
 				new IllegalArgumentException())).isEqualTo(DeserializationHandlerResponse.CONTINUE);
-		assertThat(handler.handle(null, new ConsumerRecord<byte[], byte[]>("foo", 0, 0, null, null),
+		assertThat(handler.handle(null, new ConsumerRecord<>("foo", 0, 0, null, null),
 				new IllegalStateException())).isEqualTo(DeserializationHandlerResponse.FAIL);
 	}
 
 	@Test
 	void viaObjectProperty() {
 		RecoveringDeserializationExceptionHandler handler = new RecoveringDeserializationExceptionHandler();
-		Map<String, Object> configs = new HashMap<String, Object>();
+		Map<String, Object> configs = new HashMap<>();
 		Recoverer rec = new Recoverer();
 		configs.put(RecoveringDeserializationExceptionHandler.KSTREAM_DESERIALIZATION_RECOVERER, rec);
 		handler.configure(configs);
 		assertThat(KafkaTestUtils.getPropertyValue(handler, "recoverer")).isSameAs(rec);
-		assertThat(handler.handle(null, new ConsumerRecord<byte[], byte[]>("foo", 0, 0, null, null),
+		assertThat(handler.handle(null, new ConsumerRecord<>("foo", 0, 0, null, null),
 				new IllegalArgumentException())).isEqualTo(DeserializationHandlerResponse.CONTINUE);
-		assertThat(handler.handle(null, new ConsumerRecord<byte[], byte[]>("foo", 0, 0, null, null),
+		assertThat(handler.handle(null, new ConsumerRecord<>("foo", 0, 0, null, null),
 				new IllegalStateException())).isEqualTo(DeserializationHandlerResponse.FAIL);
 	}
 
 	@Test
 	void withNoRecoverer() {
 		RecoveringDeserializationExceptionHandler handler = new RecoveringDeserializationExceptionHandler();
-		assertThat(handler.handle(null, new ConsumerRecord<byte[], byte[]>("foo", 0, 0, null, null),
+		assertThat(handler.handle(null, new ConsumerRecord<>("foo", 0, 0, null, null),
 				new IllegalArgumentException())).isEqualTo(DeserializationHandlerResponse.FAIL);
 	}