From a6bd88385757346cceb1ddba48b3167004974af1 Mon Sep 17 00:00:00 2001
From: Jiri Pechanec <jpechane@redhat.com>
Date: Fri, 3 Nov 2017 10:56:36 +0100
Subject: [PATCH] DBZ-432 Rebased to Kafka 1.0.0

---
 .../java/io/debezium/transforms/UnwrapFromEnvelopeTest.java   | 4 ++--
 pom.xml                                                       | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/debezium-core/src/test/java/io/debezium/transforms/UnwrapFromEnvelopeTest.java b/debezium-core/src/test/java/io/debezium/transforms/UnwrapFromEnvelopeTest.java
index 12528845c..ef8f0b9e6 100644
--- a/debezium-core/src/test/java/io/debezium/transforms/UnwrapFromEnvelopeTest.java
+++ b/debezium-core/src/test/java/io/debezium/transforms/UnwrapFromEnvelopeTest.java
@@ -64,7 +64,7 @@ private SourceRecord createDeleteRecord() {
         Envelope envelope = Envelope.defineSchema()
                 .withName("dummy.Envelope")
                 .withRecord(recordSchema)
-                .withSource(null)
+                .withSource(SchemaBuilder.struct().build())
                 .build();
         final Struct before = new Struct(recordSchema);
         before.put("id", (byte)1);
@@ -77,7 +77,7 @@ private SourceRecord createCreateRecord() {
         Envelope envelope = Envelope.defineSchema()
                 .withName("dummy.Envelope")
                 .withRecord(recordSchema)
-                .withSource(null)
+                .withSource(SchemaBuilder.struct().build())
                 .build();
         final Struct before = new Struct(recordSchema);
         before.put("id", (byte)1);
diff --git a/pom.xml b/pom.xml
index a71ce1f2f..374bbbf17 100644
--- a/pom.xml
+++ b/pom.xml
@@ -55,11 +55,11 @@
         <maven.compiler.target>1.8</maven.compiler.target>
 
         <!-- Kafka and it's dependencies MUST reflect what the Kafka version uses -->
-        <version.kafka>0.11.0.1</version.kafka>
+        <version.kafka>1.0.0</version.kafka>
         <version.kafka.scala>2.11</version.kafka.scala>
         <version.curator>2.11.0</version.curator>
         <version.zookeeper>3.4.10</version.zookeeper>
-        <version.jackson>2.8.5</version.jackson>
+        <version.jackson>2.9.1</version.jackson>
         <version.org.slf4j>1.7.25</version.org.slf4j>
         <version.log4j>1.2.17</version.log4j>
         <!-- check new release version at https://github.com/confluentinc/schema-registry/releases -->