[camel] 02/02: (chores) camel-kafka: remove deprecated method usages

[orpiske]

This is an automated email from the ASF dual-hosted git repository.

orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git

commit cd2ef6fcf520f6477e1e7eb6012b62ed666c3da1
Author: Otavio Rodolfo Piske <angusyo...@gmail.com>
AuthorDate: Tue May 31 11:00:37 2022 +0200

    (chores) camel-kafka: remove deprecated method usages
---
 .../java/org/apache/camel/component/kafka/KafkaProducerTest.java    | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerTest.java
 
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerTest.java
index 3261e2a459a..86cc411317a 100644
--- 
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerTest.java
+++ 
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerTest.java
@@ -87,7 +87,7 @@ public class KafkaProducerTest {
         fromEndpoint.doBuild();
         assertTrue(fromEndpoint.getKafkaClientFactory() instanceof 
DefaultKafkaClientFactory);
 
-        RecordMetadata rm = new RecordMetadata(null, 0, 0, 0, 0L, 0, 0);
+        RecordMetadata rm = new RecordMetadata(null, 0, 0, 0, 0, 0);
         Future future = Mockito.mock(Future.class);
         Mockito.when(future.get()).thenReturn(rm);
         org.apache.kafka.clients.producer.KafkaProducer kp
@@ -154,7 +154,7 @@ public class KafkaProducerTest {
         ArgumentCaptor<Callback> callBackCaptor = 
ArgumentCaptor.forClass(Callback.class);
         
Mockito.verify(producer.getKafkaProducer()).send(any(ProducerRecord.class), 
callBackCaptor.capture());
         Callback kafkaCallback = callBackCaptor.getValue();
-        kafkaCallback.onCompletion(new RecordMetadata(null, 0, 0, 0, 0L, 0, 
0), null);
+        kafkaCallback.onCompletion(new RecordMetadata(null, 0, 0, 0, 0, 0), 
null);
         assertRecordMetadataExists();
     }
 
@@ -177,7 +177,7 @@ public class KafkaProducerTest {
         Mockito.verify(exchange).setException(isA(ApiException.class));
         Mockito.verify(callback).done(eq(true));
         Callback kafkaCallback = callBackCaptor.getValue();
-        kafkaCallback.onCompletion(new RecordMetadata(null, 0, 0, 0, 0L, 0, 
0), null);
+        kafkaCallback.onCompletion(new RecordMetadata(null, 0, 0, 0, 0, 0), 
null);
         assertRecordMetadataExists();
     }