Skip to content

Commit 7a19129

Browse files
committed
Use correct ConsumerRecord ctor in the test
1 parent 9510d44 commit 7a19129

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

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

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright 2017-2019 the original author or authors.
2+
* Copyright 2017-2022 the original author or authors.
33
*
44
* Licensed under the Apache License, Version 2.0 (the "License");
55
* you may not use this file except in compliance with the License.
@@ -216,7 +216,8 @@ public ConcurrentKafkaListenerContainerFactory kafkaListenerContainerFactory() {
216216
factory.getContainerProperties().setMissingTopicsFatal(false);
217217
factory.setRecordInterceptor(record ->
218218
new ConsumerRecord(record.topic(), record.partition(), record.offset(), 0L,
219-
TimestampType.NO_TIMESTAMP_TYPE, 0, 0, record.key(), record.value(), record.headers(),
219+
TimestampType.NO_TIMESTAMP_TYPE, 0L, record.serializedKeySize(),
220+
record.serializedValueSize(), record.key(), record.value(), record.headers(),
220221
Optional.empty())
221222
);
222223
return factory;

0 commit comments

Comments
 (0)