Skip to content

Commit

Permalink
Fix print the schema compatibility strategy
Browse files Browse the repository at this point in the history
Signed-off-by: Zixuan Liu <[email protected]>
  • Loading branch information
nodece committed Feb 14, 2022
1 parent 3019d42 commit 4078ec1
Showing 1 changed file with 3 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -1729,7 +1729,9 @@ private class GetSchemaCompatibilityStrategy extends CliCommand {
@Override
void run() throws PulsarAdminException {
String persistentTopic = validatePersistentTopic(params);
print(getAdmin().topicPolicies().getSchemaCompatibilityStrategy(persistentTopic, applied));
SchemaCompatibilityStrategy strategy =
getAdmin().topicPolicies().getSchemaCompatibilityStrategy(persistentTopic, applied);
print(strategy == null ? "null" : strategy.name());
}
}

Expand Down

0 comments on commit 4078ec1

Please sign in to comment.