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

DBZ-2152 Adding fix annotations to new tests

Browse Source
This commit is contained in:
Dave Cumberland 2020-06-05 08:23:27 -07:00 committed by Chris Cranford
parent a17e4cbad0
commit 4254e29667
1 changed files with 12 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
debezium-core/src/test/java/io/debezium/transforms/outbox/EventRouterTest.java
View File

@ -8,15 +8,11 @@
import static org.apache.kafka.connect.transforms.util.Requirements.requireStruct;
import static org.fest.assertions.Assertions.assertThat;
import io.debezium.connector.AbstractSourceInfo;
import io.debezium.data.Envelope;
import io.debezium.data.VerifyRecord;
import io.debezium.doc.FixFor;
import io.debezium.time.Timestamp;
import java.nio.charset.StandardCharsets;
import java.time.Instant;
import java.util.HashMap;
import java.util.Map;
import org.apache.kafka.connect.data.Schema;
import org.apache.kafka.connect.data.SchemaBuilder;
import org.apache.kafka.connect.data.Struct;
@ -29,6 +25,12 @@
import org.junit.Test;
import org.junit.rules.ExpectedException;
import io.debezium.connector.AbstractSourceInfo;
import io.debezium.data.Envelope;
import io.debezium.data.VerifyRecord;
import io.debezium.doc.FixFor;
import io.debezium.time.Timestamp;
/**
* Unit tests for {@link EventRouter}
*
@ -692,6 +694,7 @@ public void shouldFailOnInvalidConfigurationForOperationBehavior() {
}
@Test
@FixFor("DBZ-2152")
public void canPassStringKey() {
// canSetDefaultMessageKey() duplicates this logic, as the current test assumes the key will be a String
final EventRouter<SourceRecord> router = new EventRouter<>();
@ -706,6 +709,7 @@ public void canPassStringKey() {
}
@Test
@FixFor("DBZ-2152")
public void canSetBinaryMessageKey() {
final byte[] eventType = "a UserCreated".getBytes(StandardCharsets.UTF_8);
final EventRouter<SourceRecord> router = new EventRouter<>();
@ -734,12 +738,14 @@ public void canSetBinaryMessageKey() {
}
@Test
@FixFor("DBZ-2152")
public void canPassBinaryKey() {
final byte[] key = "a binary key".getBytes(StandardCharsets.UTF_8);
canPassKeyByType(SchemaBuilder.bytes(), key);
}
@Test
@FixFor("DBZ-2152")
public void canPassIntKey() {
final int key = 54321;
canPassKeyByType(SchemaBuilder.int32(), key);
@ -769,6 +775,7 @@ private void canPassKeyByType(SchemaBuilder keyType, Object key) {
}
@Test
@FixFor("DBZ-2152")
public void canPassBinaryMessage() {
final byte[] value = "a binary message".getBytes(StandardCharsets.UTF_8);
final String key = "a key";