[kafka] branch trunk updated: MINOR: Replace null with an actual value for timestamp field in InsertField SMT unit tests (#8649)

[kkarantasis]

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

kkarantasis pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 9bc96d5  MINOR: Replace null with an actual value for timestamp field 
in InsertField SMT unit tests (#8649)
9bc96d5 is described below

commit 9bc96d54f8953d190a1fb6478a0656f049ee3b32
Author: Arjun Satish <wickni...@users.noreply.github.com>
AuthorDate: Tue May 12 16:12:31 2020 -0700

    MINOR: Replace null with an actual value for timestamp field in InsertField 
SMT unit tests (#8649)
    
    Add actual values instead of just passing null in unit tests that check the 
behavior of the InsertField SMT when trying to insert a field that takes its 
value from the Kafka record timestamp.
    
    Reviewers: Chris Egerton <chr...@confluent.io>, Konstantine Karantasis 
<konstant...@confluent.io>
---
 .../org/apache/kafka/connect/transforms/InsertFieldTest.java   | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/InsertFieldTest.java
 
b/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/InsertFieldTest.java
index dc6611c..b572c09 100644
--- 
a/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/InsertFieldTest.java
+++ 
b/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/InsertFieldTest.java
@@ -26,6 +26,7 @@ import org.junit.After;
 import org.junit.Test;
 
 import java.util.Collections;
+import java.util.Date;
 import java.util.HashMap;
 import java.util.Map;
 
@@ -61,7 +62,7 @@ public class InsertFieldTest {
         final Schema simpleStructSchema = 
SchemaBuilder.struct().name("name").version(1).doc("doc").field("magic", 
Schema.OPTIONAL_INT64_SCHEMA).build();
         final Struct simpleStruct = new 
Struct(simpleStructSchema).put("magic", 42L);
 
-        final SourceRecord record = new SourceRecord(null, null, "test", 0, 
simpleStructSchema, simpleStruct);
+        final SourceRecord record = new SourceRecord(null, null, "test", 0, 
null, null, simpleStructSchema, simpleStruct, 789L);
         final SourceRecord transformedRecord = xformValue.apply(record);
 
         assertEquals(simpleStructSchema.name(), 
transformedRecord.valueSchema().name());
@@ -78,7 +79,7 @@ public class InsertFieldTest {
         assertEquals(0, ((Struct) 
transformedRecord.value()).getInt32("partition_field").intValue());
 
         assertEquals(Timestamp.builder().optional().build(), 
transformedRecord.valueSchema().field("timestamp_field").schema());
-        assertEquals(null, ((Struct) 
transformedRecord.value()).getInt64("timestamp_field"));
+        assertEquals(789L, ((Date) ((Struct) 
transformedRecord.value()).get("timestamp_field")).getTime());
 
         assertEquals(Schema.OPTIONAL_STRING_SCHEMA, 
transformedRecord.valueSchema().field("instance_id").schema());
         assertEquals("my-instance-id", ((Struct) 
transformedRecord.value()).getString("instance_id"));
@@ -101,18 +102,17 @@ public class InsertFieldTest {
         xformValue.configure(props);
 
         final SourceRecord record = new SourceRecord(null, null, "test", 0,
-                null, Collections.singletonMap("magic", 42L));
+                null, null, null, Collections.singletonMap("magic", 42L), 
123L);
 
         final SourceRecord transformedRecord = xformValue.apply(record);
 
         assertEquals(42L, ((Map<?, ?>) 
transformedRecord.value()).get("magic"));
         assertEquals("test", ((Map<?, ?>) 
transformedRecord.value()).get("topic_field"));
         assertEquals(0, ((Map<?, ?>) 
transformedRecord.value()).get("partition_field"));
-        assertEquals(null, ((Map<?, ?>) 
transformedRecord.value()).get("timestamp_field"));
+        assertEquals(123L, ((Map<?, ?>) 
transformedRecord.value()).get("timestamp_field"));
         assertEquals("my-instance-id", ((Map<?, ?>) 
transformedRecord.value()).get("instance_id"));
     }
 
-
     @Test
     public void 
insertConfiguredFieldsIntoTombstoneEventWithoutSchemaLeavesValueUnchanged() {
         final Map<String, Object> props = new HashMap<>();