[pulsar] branch master updated: Get schema info with topic partition (#4751)

[penghui]

This is an automated email from the ASF dual-hosted git repository.

penghui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 8b197c6  Get schema info with topic partition (#4751)
8b197c6 is described below

commit 8b197c6bcb42dd26ed449cfe04b8b12495f3d98e
Author: congbo <39078850+congbobo...@users.noreply.github.com>
AuthorDate: Fri Jul 19 18:22:23 2019 +0800

    Get schema info with topic partition (#4751)
---
 .../java/org/apache/pulsar/broker/admin/v2/SchemasResource.java    | 7 ++++++-
 .../java/org/apache/pulsar/broker/admin/AdminApiSchemaTest.java    | 6 ++++++
 2 files changed, 12 insertions(+), 1 deletion(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/SchemasResource.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/SchemasResource.java
index 49df9a9..1f61d4a 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/SchemasResource.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/SchemasResource.java
@@ -292,7 +292,12 @@ public class SchemasResource extends AdminResource {
     }
 
     private String buildSchemaId(String tenant, String namespace, String 
topic) {
-        return TopicName.get("persistent", tenant, namespace, 
topic).getSchemaName();
+        TopicName topicName = TopicName.get("persistent", tenant, namespace, 
topic);
+        if (topicName.isPartitioned()) {
+            return 
TopicName.get(topicName.getPartitionedTopicName()).getSchemaName();
+        } else {
+            return topicName.getSchemaName();
+        }
     }
 
     private void validateDestinationAndAdminOperation(String tenant, String 
namespace, String topic,
diff --git 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiSchemaTest.java
 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiSchemaTest.java
index 2f163fe..c24058a 100644
--- 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiSchemaTest.java
+++ 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiSchemaTest.java
@@ -121,5 +121,11 @@ public class AdminApiSchemaTest extends 
MockedPulsarServiceBaseTest {
         log.info("Read schema of topic {} : {}", topicName, readSi);
 
         assertEquals(si, readSi);
+
+        readSi = admin.schemas().getSchemaInfo(topicName + "-partition-0");
+        log.info("Read schema of topic {} : {}", topicName, readSi);
+
+        assertEquals(si, readSi);
+
     }
 }