alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-432 Rebased to Kafka 1.0.0

Browse Source
This commit is contained in:
Jiri Pechanec 2017-11-03 10:56:36 +01:00 committed by Gunnar Morling
parent 039566e717
commit a6bd883857
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
debezium-core/src/test/java/io/debezium/transforms/UnwrapFromEnvelopeTest.java
View File

@ -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);

4
pom.xml
View File

@ -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 -->