Skip to content

Commit bef1fdd

Browse files
committed
chore: add test failing when expected is INT8 but input is INT16
1 parent 99a8162 commit bef1fdd

File tree

1 file changed

+21
-1
lines changed

1 file changed

+21
-1
lines changed

src/test/java/io/aiven/kafka/connect/transforms/FilterByFieldValueTest.java

Lines changed: 21 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -138,6 +138,24 @@ void shouldFilterOutKeyRecordsNotEqualsToId() {
138138
.isEqualTo(record);
139139
}
140140

141+
@Test
142+
void shouldFilterOutRecordNotEqualsToIntId() {
143+
final FilterByFieldValue<SourceRecord> filter = new FilterByFieldValue.Value<>();
144+
filter.configure(Map.of(
145+
"field.name", "EventId",
146+
"field.value", "4690",
147+
"field.value.matches", "true"
148+
));
149+
150+
assertThat(filter.apply(prepareRecord(() -> "A42", () -> Map.of("EventId", 4663))))
151+
.as("Record with id not equal to 'A132' should be filtered out")
152+
.isNull();
153+
final SourceRecord record = prepareRecord(() -> "A42", () -> Map.of("EventId", 4690));
154+
assertThat(filter.apply(record))
155+
.as("Record with id equal to '4690' should not be filtered out")
156+
.isEqualTo(record);
157+
}
158+
141159
@Test
142160
void shouldFilterOutMapValueRecordsWithRegex() {
143161
final FilterByFieldValue<SourceRecord> filterByFieldValue = new FilterByFieldValue.Value<>();
@@ -147,7 +165,9 @@ void shouldFilterOutMapValueRecordsWithRegex() {
147165
configs.put("field.value.matches", "false");
148166
filterByFieldValue.configure(configs);
149167

150-
assertThat(filterByFieldValue.apply(prepareRecord(() -> "A42", () -> Map.of("language", "Javascript"))))
168+
assertThat(filterByFieldValue.apply(
169+
prepareRecord(() -> "A42", () -> Map.of("language", "Javascript"))
170+
))
151171
.as("The record should be filtered out")
152172
.isNull();
153173
final SourceRecord record = prepareRecord(() -> "A42", () -> Map.of("language", "Rust"));

0 commit comments

Comments
 (0)