wip

confluentinc · Sep 1, 2022 · 0205c2a · 0205c2a
1 parent 2d5466b
commit 0205c2a
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 9 deletions.
diff --git a/core/src/test/java/org/apache/druid/java/util/emitter/service/SegmentMetadataEventTest.java b/core/src/test/java/org/apache/druid/java/util/emitter/service/SegmentMetadataEventTest.java
@@ -32,9 +32,9 @@ public class SegmentMetadataEventTest
   {
     SegmentMetadataEvent event = new SegmentMetadataEvent(
         "dummy_datasource",
-        new DateTime("2001-01-01"),
-        new DateTime("2001-01-01"),
-        new DateTime("2001-01-01"),
+        new DateTime("2001-01-01T00:00:00.000Z"),
+        new DateTime("2001-01-01T00:00:00.000Z"),
+        new DateTime("2001-01-01T00:00:00.000Z"),
         "dummy_version",
         java.lang.Boolean.TRUE
     );
@@ -43,9 +43,9 @@ public class SegmentMetadataEventTest
         ImmutableMap.<String, Object>builder()
             .put(SegmentMetadataEvent.FEED, "segment_metadata")
             .put(SegmentMetadataEvent.DATASOURCE, "dummy_datasource")
-            .put(SegmentMetadataEvent.CREATED_TIME, new DateTime("2001-01-01T00:00:00.000-06:00"))
-            .put(SegmentMetadataEvent.START_TIME, new DateTime("2001-01-01T00:00:00.000-06:00"))
-            .put(SegmentMetadataEvent.END_TIME, new DateTime("2001-01-01T00:00:00.000-06:00"))
+            .put(SegmentMetadataEvent.CREATED_TIME, new DateTime("2001-01-01T00:00:00.000Z"))
+            .put(SegmentMetadataEvent.START_TIME, new DateTime("2001-01-01T00:00:00.000Z"))
+            .put(SegmentMetadataEvent.END_TIME, new DateTime("2001-01-01T00:00:00.000Z"))
             .put(SegmentMetadataEvent.VERSION, "dummy_version")
             .put(SegmentMetadataEvent.IS_COMPACTED, java.lang.Boolean.TRUE)
             .build(),

diff --git a/extensions-contrib/kafka-segment-metadata-emitter/pom.xml b/extensions-contrib/kafka-segment-metadata-emitter/pom.xml
@@ -122,9 +122,16 @@
       <version>${protobuf.version}</version>
     </dependency>
     <dependency>
-      <groupId>com.google.protobuf</groupId>
-      <artifactId>protobuf-java-util</artifactId>
-      <version>${protobuf.version}</version>
+      <groupId>joda-time</groupId>
+      <artifactId>joda-time</artifactId>
+      <version>2.10.5</version>
+      <scope>provided</scope>
+    </dependency>
+    <dependency>
+      <groupId>io.netty</groupId>
+      <artifactId>netty-common</artifactId>
+      <version>4.1.68.Final</version>
+      <scope>provided</scope>
     </dependency>
   </dependencies>
   <build>