Fix compatibility with current Kafka Client

Author: artembilan

spring-kafka/src/test/java/org/springframework/kafka/listener/DefaultErrorHandlerSeekAfterCommitExceptionBatchAckTests.java

@@ -149,7 +149,7 @@ public ConsumerFactory consumerFactory() {
 			ConsumerFactory consumerFactory = mock(ConsumerFactory.class);
 			final Consumer consumer = consumer();
 			given(consumerFactory.createConsumer("grp", "", "-0", KafkaTestUtils.defaultPropertyOverrides()))
-				.willReturn(consumer);
+					.willReturn(consumer);
 			return consumerFactory;
 		}
 
@@ -226,7 +226,7 @@ ConcurrentKafkaListenerContainerFactory kafkaListenerContainerFactory() {
 			factory.setConsumerFactory(consumerFactory());
 			factory.getContainerProperties().setAckMode(AckMode.BATCH);
 			factory.getContainerProperties().setDeliveryAttemptHeader(true);
-			factory.setRecordInterceptor((record, consumer) -> {
+			factory.setRecordInterceptor((record) -> {
 				Config.this.deliveryAttempt = record.headers().lastHeader(KafkaHeaders.DELIVERY_ATTEMPT);
 				return record;
 			});

spring-kafka/src/test/java/org/springframework/kafka/listener/DefaultErrorHandlerSeekAfterCommitExceptionTests.java

@@ -149,7 +149,7 @@ public ConsumerFactory consumerFactory() {
 			ConsumerFactory consumerFactory = mock(ConsumerFactory.class);
 			final Consumer consumer = consumer();
 			given(consumerFactory.createConsumer("grp", "", "-0", KafkaTestUtils.defaultPropertyOverrides()))
-				.willReturn(consumer);
+					.willReturn(consumer);
 			return consumerFactory;
 		}
 
@@ -226,7 +226,7 @@ ConcurrentKafkaListenerContainerFactory kafkaListenerContainerFactory() {
 			factory.setConsumerFactory(consumerFactory());
 			factory.getContainerProperties().setAckMode(AckMode.RECORD);
 			factory.getContainerProperties().setDeliveryAttemptHeader(true);
-			factory.setRecordInterceptor((record, consumer) -> {
+			factory.setRecordInterceptor((record) -> {
 				Config.this.deliveryAttempt = record.headers().lastHeader(KafkaHeaders.DELIVERY_ATTEMPT);
 				return record;
 			});