Remove redundant 'public' modifier in LookupService.
@@ -57,7 +57,7 @@ public interface LookupService extends AutoCloseable {
* topic-name
* @return a pair of addresses, representing the logical and physical address of the broker that serves given topic
*/
- public CompletableFuture<Pair<InetSocketAddress, InetSocketAddress>> getBroker(TopicName topicName);
+ CompletableFuture<Pair<InetSocketAddress, InetSocketAddress>> getBroker(TopicName topicName);
/**
* Returns {@link PartitionedTopicMetadata} for a given topic.
@@ -65,7 +65,7 @@ public interface LookupService extends AutoCloseable {
* @param topicName topic-name
* @return
*/
- public CompletableFuture<PartitionedTopicMetadata> getPartitionedTopicMetadata(TopicName topicName);
+ CompletableFuture<PartitionedTopicMetadata> getPartitionedTopicMetadata(TopicName topicName);
/**
* Returns current SchemaInfo {@link SchemaInfo} for a given topic.
@@ -73,7 +73,7 @@ public interface LookupService extends AutoCloseable {
* @param topicName topic-name
* @return SchemaInfo
*/
- public CompletableFuture<Optional<SchemaInfo>> getSchema(TopicName topicName);
+ CompletableFuture<Optional<SchemaInfo>> getSchema(TopicName topicName);
/**
* Returns specific version SchemaInfo {@link SchemaInfo} for a given topic.
@@ -82,14 +82,14 @@ public interface LookupService extends AutoCloseable {
* @param version schema info version
* @return SchemaInfo
*/
- public CompletableFuture<Optional<SchemaInfo>> getSchema(TopicName topicName, byte[] version);
+ CompletableFuture<Optional<SchemaInfo>> getSchema(TopicName topicName, byte[] version);
/**
* Returns broker-service lookup api url.
*
* @return
*/
- public String getServiceUrl();
+ String getServiceUrl();
/**
* Returns all the topics name for a given namespace.
@@ -97,6 +97,6 @@ public interface LookupService extends AutoCloseable {
* @param namespace : namespace-name
* @return
*/
- public CompletableFuture<List<String>> getTopicsUnderNamespace(NamespaceName namespace, Mode mode);
+ CompletableFuture<List<String>> getTopicsUnderNamespace(NamespaceName namespace, Mode mode);
}
