Skip to content

Commit e1c59c5

Browse files
garyrussellartembilan
authored andcommitted
Fix test compatibility with the RecordInterceptor
**Cherry-pick to `2.8.x` & `2.7.x`**
1 parent 549e243 commit e1c59c5

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -217,7 +217,7 @@ public ConcurrentKafkaListenerContainerFactory kafkaListenerContainerFactory() {
217217

218218
@Override
219219
@Nullable
220-
public ConsumerRecord intercept(ConsumerRecord record, Consumer consumer) {
220+
public ConsumerRecord intercept(ConsumerRecord record) {
221221
return new ConsumerRecord(record.topic(), record.partition(), record.offset(), 0L,
222222
TimestampType.NO_TIMESTAMP_TYPE, 0, 0, record.key(), record.value(), record.headers(),
223223
Optional.empty());

0 commit comments

Comments
 (0)