diff --git a/src/main/java/com/purbon/kafka/topology/serdes/TopologyCustomDeserializer.java b/src/main/java/com/purbon/kafka/topology/serdes/TopologyCustomDeserializer.java index e28da4cea..f94668597 100644 --- a/src/main/java/com/purbon/kafka/topology/serdes/TopologyCustomDeserializer.java +++ b/src/main/java/com/purbon/kafka/topology/serdes/TopologyCustomDeserializer.java @@ -427,17 +427,6 @@ private Optional doStreamsElements(JsonParser parser, JsonNode n + " might require both read and write topics as per its " + "nature it is always reading and writing into Apache Kafka, be aware if you notice problems."); } - if (topics.get(KStream.READ_TOPICS).isEmpty()) { - // should have at minimum read topics defined as we could think of write topics as internal - // topics being - // auto created. - throw new IOException( - "Kafka Streams application with Id " - + ks.getApplicationId() - + " and principal " - + ks.getPrincipal() - + " have missing read topics. This field is required."); - } } return Optional.of(new PlatformSystem(streams)); } diff --git a/src/test/java/com/purbon/kafka/topology/TopologySerdesTest.java b/src/test/java/com/purbon/kafka/topology/TopologySerdesTest.java index b86c39c35..f3ec66fc2 100644 --- a/src/test/java/com/purbon/kafka/topology/TopologySerdesTest.java +++ b/src/test/java/com/purbon/kafka/topology/TopologySerdesTest.java @@ -86,11 +86,6 @@ public void testStreamsParsingOnlyReadTopicsShouldNotParseAsNull() { } } - @Test(expected = TopologyParsingException.class) - public void testStreamsParsingOnlyWriteTopicsShoulRaiseAnException() { - parser.deserialise(TestUtils.getResourceFile("/descriptor-streams-only-write.yaml")); - } - @Test public void testDynamicFirstLevelAttributes() { Topology topology = diff --git a/src/test/resources/descriptor-streams-only-write.yaml b/src/test/resources/descriptor-streams-only-write.yaml deleted file mode 100644 index 831e2499b..000000000 --- a/src/test/resources/descriptor-streams-only-write.yaml +++ /dev/null @@ -1,11 +0,0 @@ ---- -context: "contextOrg" -source: "source" -projects: - - name: "foo" - streams: - - principal: "User:App0" - topics: - write: - - "topicA" - - "topicB" \ No newline at end of file