diff --git a/src/test/java/otter/jet/plaintext/PlainTextMessageReaderTest.java b/src/test/java/otter/jet/plaintext/PlainTextMessageReaderTest.java index 4809f12..5d795d0 100644 --- a/src/test/java/otter/jet/plaintext/PlainTextMessageReaderTest.java +++ b/src/test/java/otter/jet/plaintext/PlainTextMessageReaderTest.java @@ -21,7 +21,7 @@ import otter.jet.store.Filters; import otter.jet.store.MessageStore; -@TestPropertySource(properties = {"read.mode=plaintext", "read.subject=plaintext"}) +@TestPropertySource(properties = {"read.mode=plaintext", "read.subject=plaintext", "read.beginTimestamp="}) class PlainTextMessageReaderTest extends AbstractIntegrationTest { private static final LocalDateTime ignoredMessageTimestamp = diff --git a/src/test/java/otter/jet/proto/AnyProtoMessageReaderTest.java b/src/test/java/otter/jet/proto/AnyProtoMessageReaderTest.java index e42e751..5f3ee49 100644 --- a/src/test/java/otter/jet/proto/AnyProtoMessageReaderTest.java +++ b/src/test/java/otter/jet/proto/AnyProtoMessageReaderTest.java @@ -28,7 +28,8 @@ properties = { "read.mode=proto", "read.subject=any_person", - "read.proto.pathToDescriptor=src/test/resources/person.desc" + "read.proto.pathToDescriptor=src/test/resources/person.desc", + "read.beginTimestamp=" }) class AnyProtoMessageReaderTest extends AbstractIntegrationTest { diff --git a/src/test/java/otter/jet/proto/SimpleProtoMessageReaderTest.java b/src/test/java/otter/jet/proto/SimpleProtoMessageReaderTest.java index ec6d3a3..0927859 100644 --- a/src/test/java/otter/jet/proto/SimpleProtoMessageReaderTest.java +++ b/src/test/java/otter/jet/proto/SimpleProtoMessageReaderTest.java @@ -28,7 +28,8 @@ "read.mode=proto", "read.subject=typed_person", "read.proto.messageTypeName=protobuf.Person", - "read.proto.pathToDescriptor=src/test/resources/person.desc" + "read.proto.pathToDescriptor=src/test/resources/person.desc", + "read.beginTimestamp=" }) class SimpleProtoMessageReaderTest extends AbstractIntegrationTest { diff --git a/src/test/resources/application-local.yml b/src/test/resources/application-local.yml index 3c3b48b..adf5b63 100644 --- a/src/test/resources/application-local.yml +++ b/src/test/resources/application-local.yml @@ -1,5 +1,6 @@ read: mode: "proto" + beginTimestamp: "" proto: pathToDescriptor: "src/test/resources/person.desc" subject: "*"