Fix #93: failed ListOffsets in Integration tests

streamnative · Feb 10, 2020 · 18d70a1 · 18d70a1
1 parent 7583f1f
commit 18d70a1
Showing 1 changed file with 3 additions and 12 deletions.
diff --git a/src/main/java/io/streamnative/kop/KafkaRequestHandler.java b/src/main/java/io/streamnative/kop/KafkaRequestHandler.java
@@ -810,18 +810,9 @@ private CompletableFuture<AbstractResponse> handleListOffsetRequestV0(KafkaHeade
                         Collections.singletonList(ListOffsetResponse.UNKNOWN_OFFSET)));
             }
 
-            // topic not exist, return UNKNOWN_TOPIC_OR_PARTITION
-            if (!topicManager.topicExists(pulsarTopic.toString())) {
-                log.warn("Topic {} not exist in topic manager while list offset.", pulsarTopic.toString());
-                partitionData = new CompletableFuture<>();
-                partitionData.complete(new ListOffsetResponse
-                        .PartitionData(
-                        Errors.UNKNOWN_TOPIC_OR_PARTITION,
-                        Collections.singletonList(ListOffsetResponse.UNKNOWN_OFFSET)));
-            } else {
-                CompletableFuture<PersistentTopic> persistentTopic = topicManager.getTopic(pulsarTopic.toString());
-                partitionData = fetchOffsetForTimestamp(persistentTopic, times, true);
-            }
+            CompletableFuture<PersistentTopic> persistentTopic = topicManager.getTopic(pulsarTopic.toString());
+            partitionData = fetchOffsetForTimestamp(persistentTopic, times, true);
+
             responseData.put(topic, partitionData);
         });