Skip to content

Commit a71febd

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

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
@@ -248,7 +248,7 @@ public ConcurrentKafkaListenerContainerFactory kafkaListenerContainerFactory() {
248248

249249
@Override
250250
@Nullable
251-
public ConsumerRecord intercept(ConsumerRecord record, Consumer consumer) {
251+
public ConsumerRecord intercept(ConsumerRecord record) {
252252
return new ConsumerRecord(record.topic(), record.partition(), record.offset(), 0L,
253253
TimestampType.NO_TIMESTAMP_TYPE, 0, 0, record.key(), record.value(), record.headers(),
254254
Optional.empty());

0 commit comments

Comments
 (0)