Uses of Class
org.apache.pulsar.client.admin.PulsarAdminException
Package
Description
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
-
Uses of PulsarAdminException in org.apache.pulsar.client.admin
Modifier and TypeClassDescriptionstatic class
Conflict Exception.static class
Connect Exception.static class
Getting Authentication Data Exception.static class
Http Error Exception.static class
Not Allowed Exception.static class
Not Authorized Exception.static class
Not Found Exception.static class
Precondition Failed Exception.static class
Server Side Error Exception.static class
Timeout Exception.Modifier and TypeMethodDescriptionvoid
Brokers.backlogQuotaCheck()
Manually trigger backlogQuotaCheck.void
Namespaces.clearNamespaceBacklog
(String namespace) Clear backlog for all topics on a namespace.void
Namespaces.clearNamespaceBacklogForSubscription
(String namespace, String subscription) Clear backlog for a given subscription on all topics on a namespace.void
Namespaces.clearNamespaceBundleBacklog
(String namespace, String bundle) Clear backlog for all topics on a namespace bundle.void
Namespaces.clearNamespaceBundleBacklogForSubscription
(String namespace, String bundle, String subscription) Clear backlog for a given subscription on all topics on a namespace bundle.void
Namespaces.clearOffloadDeleteLag
(String namespace) Clear the offload deletion lag for a namespace.void
Namespaces.clearProperties
(String namespace) Clear all properties of a namespace.Topics.compactionStatus
(String topic) Check the status of an ongoing compaction for a topic.void
Clusters.createCluster
(String cluster, ClusterData clusterData) Create a new cluster.void
Clusters.createFailureDomain
(String cluster, String domainName, FailureDomain domain) Create a domain into cluster.void
Functions.createFunction
(FunctionConfig functionConfig, String fileName) Create a new function.void
Functions.createFunctionWithUrl
(FunctionConfig functionConfig, String pkgUrl) Create a new function with package url.void
Topics.createMissedPartitions
(String topic) Create missed partitions for partitioned topic.void
Namespaces.createNamespace
(String namespace) Create a new namespace.void
Namespaces.createNamespace
(String namespace, int numBundles) Create a new namespace.void
Namespaces.createNamespace
(String namespace, Set<String> clusters) Create a new namespace.void
Namespaces.createNamespace
(String namespace, BundlesData bundlesData) Create a new namespace.void
Namespaces.createNamespace
(String namespace, Policies policies) Create a new namespace.void
Clusters.createNamespaceIsolationPolicy
(String cluster, String policyName, NamespaceIsolationData namespaceIsolationData) Create a namespace isolation policy for a cluster.default void
Topics.createNonPartitionedTopic
(String topic) Create a non-partitioned topic.void
Topics.createNonPartitionedTopic
(String topic, Map<String, String> properties) Create a non-partitioned topic.void
NonPersistentTopics.createPartitionedTopic
(String topic, int numPartitions) Deprecated.Create a partitioned topic.default void
Topics.createPartitionedTopic
(String topic, int numPartitions) Create a partitioned topic.void
Topics.createPartitionedTopic
(String topic, int numPartitions, Map<String, String> properties) Create a partitioned topic.void
Properties.createProperty
(String property, TenantInfo config) Deprecated.Create a new property.void
ResourceGroups.createResourceGroup
(String name, ResourceGroup resourcegroup) Create a new resourcegroup.void
Schemas.createSchema
(String topic, PostSchemaPayload schemaPayload) Create a schema for a given topic.void
Schemas.createSchema
(String topic, org.apache.pulsar.common.schema.SchemaInfo schemaInfo) Create a schema for a given topic with the provided schema info.void
Sinks.createSink
(SinkConfig sinkConfig, String fileName) Create a new sink.void
Sinks.createSinkWithUrl
(SinkConfig sinkConfig, String pkgUrl) Create a new sink with package url.void
Sources.createSource
(SourceConfig sourceConfig, String fileName) Create a new source.void
Sources.createSourceWithUrl
(SourceConfig sourceConfig, String pkgUrl) Create a new source with package url.default void
Topics.createSubscription
(String topic, String subscriptionName, org.apache.pulsar.client.api.MessageId messageId) Create a new subscription on a topic.default void
Topics.createSubscription
(String topic, String subscriptionName, org.apache.pulsar.client.api.MessageId messageId, boolean replicated) Create a new subscription on a topic.void
Topics.createSubscription
(String topic, String subscriptionName, org.apache.pulsar.client.api.MessageId messageId, boolean replicated, Map<String, String> properties) Create a new subscription on a topic.void
Tenants.createTenant
(String tenant, TenantInfo config) Create a new tenant.void
Delete the specified package.void
Delete a topic.default void
void
Delete a topic.void
Namespaces.deleteBookieAffinityGroup
(String namespace) Delete bookie affinity group configured for a namespace.void
Bookies.deleteBookieRackInfo
(String bookieAddress) Remove rack placement information for a specific bookie in the cluster.void
Clusters.deleteCluster
(String cluster) Delete an existing cluster.void
Brokers.deleteDynamicConfiguration
(String configName) It deletes dynamic configuration value into ZooKeeper.void
Clusters.deleteFailureDomain
(String cluster, String domainName) Delete a domain in cluster.void
Functions.deleteFunction
(String tenant, String namespace, String function) Delete an existing function.void
Namespaces.deleteNamespace
(String namespace) Delete an existing namespace.void
Namespaces.deleteNamespace
(String namespace, boolean force) Delete an existing namespace.void
Namespaces.deleteNamespaceAntiAffinityGroup
(String namespace) Delete anti-affinity group name for a namespace.void
Namespaces.deleteNamespaceBundle
(String namespace, String bundleRange) Delete an existing bundle in a namespace.void
Namespaces.deleteNamespaceBundle
(String namespace, String bundleRange, boolean force) Delete an existing bundle in a namespace.void
Clusters.deleteNamespaceIsolationPolicy
(String cluster, String policyName) Delete a namespace isolation policy for a cluster.void
Topics.deletePartitionedTopic
(String topic) Delete a partitioned topic.default void
Topics.deletePartitionedTopic
(String topic, boolean force) void
Topics.deletePartitionedTopic
(String topic, boolean force, boolean deleteSchema) Delete a partitioned topic.void
Properties.deleteProperty
(String property) Deprecated.Delete an existing property.void
ResourceGroups.deleteResourceGroup
(String resourcegroup) Delete an existing resourcegroup.void
Schemas.deleteSchema
(String topic) Delete the schema associated with a given topic.void
Sinks.deleteSink
(String tenant, String namespace, String sink) Delete an existing sink.void
Sources.deleteSource
(String tenant, String namespace, String source) Delete an existing source.void
Topics.deleteSubscription
(String topic, String subName) Delete a subscription.void
Topics.deleteSubscription
(String topic, String subName, boolean force) Delete a subscription.void
Tenants.deleteTenant
(String tenant) Delete an existing tenant.void
Tenants.deleteTenant
(String tenant, boolean force) Delete an existing tenant.void
Topics.disableDeduplication
(String topic) Deprecated.void
Download a package from the package management service.void
Functions.downloadFunction
(String destinationFile, String path) Download Function Code.void
Functions.downloadFunction
(String destinationFile, String tenant, String namespace, String function) Download Function Code.void
Topics.enableDeduplication
(String topic, boolean enabled) Deprecated.org.apache.pulsar.client.api.Message<byte[]>
Topics.examineMessage
(String topic, String initialPosition, long messagePosition) Examine a specific message on a topic by position relative to the earliest or the latest message.CompletableFuture<org.apache.pulsar.client.api.Message<byte[]>>
Topics.examineMessageAsync
(String topic, String initialPosition, long messagePosition) Examine a specific message on a topic by position relative to the earliest or the latest message.void
Topics.expireMessages
(String topic, String subscriptionName, long expireTimeInSeconds) Expire all messages older than given N (expireTimeInSeconds) seconds for a given subscription.void
Topics.expireMessages
(String topic, String subscriptionName, org.apache.pulsar.client.api.MessageId messageId, boolean isExcluded) Expire all messages older than given N (expireTimeInSeconds) seconds for a given subscription.void
Topics.expireMessagesForAllSubscriptions
(String topic, long expireTimeInSeconds) Expire all messages older than given N seconds for all subscriptions of the persistent-topic.Brokers.getActiveBrokers
(String cluster) Get the list of active brokers in the cluster.Brokers.getAllDynamicConfigurations()
Get values of all overridden dynamic-configs.BrokerStats.getAllocatorStats
(String allocatorName) Get the stats for the Netty allocator.List<org.apache.pulsar.common.schema.SchemaInfo>
Schemas.getAllSchemas
(String topic) Get all version schemas topic.Namespaces.getAntiAffinityNamespaces
(String tenant, String cluster, String namespaceAntiAffinityGroup) Get all namespaces that grouped with given anti-affinity group.Worker.getAssignments()
Get the function assignment among the cluster.Namespaces.getAutoSubscriptionCreation
(String namespace) Get the autoSubscriptionCreation info within a namespace.Namespaces.getAutoTopicCreation
(String namespace) Get the autoTopicCreation info within a namespace.Namespaces.getBacklogQuotaMap
(String namespace) Get backlog quota map on a namespace.TopicPolicies.getBacklogQuotaMap
(String topic) Get backlog quota map for a topic.TopicPolicies.getBacklogQuotaMap
(String topic, boolean applied) Get applied backlog quota map for a topic.Topics.getBacklogQuotaMap
(String topic) Deprecated.Topics.getBacklogQuotaMap
(String topic, boolean applied) Deprecated.Topics.getBacklogSizeByMessageId
(String topic, org.apache.pulsar.client.api.MessageId messageId) Get backlog size by a message ID.Namespaces.getBookieAffinityGroup
(String namespace) Get bookie affinity group configured for a namespace.Bookies.getBookieRackInfo
(String bookieAddress) Gets the rack placement information for a specific bookie in the cluster.Bookies.getBookies()
Gets discovery information for all the bookies in the cluster.Bookies.getBookiesRackInfo()
Gets the rack placement information for all the bookies in the cluster.Clusters.getBrokersWithNamespaceIsolationPolicy
(String cluster) Returns list of active brokers with namespace-isolation policies attached to it.Clusters.getBrokerWithNamespaceIsolationPolicy
(String cluster, String broker) Returns active broker with namespace-isolation policies attached to it.Sinks.getBuiltInSinks()
Fetches a list of supported Pulsar IO sinks currently running in cluster mode.Sources.getBuiltInSources()
Fetches a list of supported Pulsar IO sources currently running in cluster mode.Lookup.getBundleRange
(String topic) Get a bundle range of a topic.Namespaces.getBundles
(String namespace) Get the list of bundles.Clusters.getCluster
(String cluster) Get the configuration data for the specified cluster.Worker.getCluster()
Get List of all workers belonging to this cluster.Worker.getClusterLeader()
Get the worker who is the leader of the cluster.Clusters.getClusters()
Get the list of clusters.Namespaces.getCompactionThreshold
(String namespace) Get the compactionThreshold for a namespace.TopicPolicies.getCompactionThreshold
(String topic) Get the compactionThreshold for a topic.TopicPolicies.getCompactionThreshold
(String topic, boolean applied) Get the compactionThreshold for a topic.Topics.getCompactionThreshold
(String topic) Deprecated.Topics.getCompactionThreshold
(String topic, boolean applied) Deprecated.ProxyStats.getConnections()
Returns Connections metrics.Functions.getConnectorsList()
Deprecated.Transactions.getCoordinatorInternalStats
(int coordinatorId, boolean metadata) Get transaction coordinator internal stats.Transactions.getCoordinatorStats()
Get transaction metadataStore stats.Transactions.getCoordinatorStatsById
(int coordinatorId) Get transaction metadataStore stats.Topics.getDeduplicationEnabled
(String topic) Deprecated.Namespaces.getDeduplicationSnapshotInterval
(String namespace) Get the deduplicationSnapshotInterval for a namespace.TopicPolicies.getDeduplicationSnapshotInterval
(String topic) Get the deduplication snapshot interval for specified topic.Topics.getDeduplicationSnapshotInterval
(String topic) Deprecated.Namespaces.getDeduplicationStatus
(String namespace) Get the deduplication status for all topics within a namespace .TopicPolicies.getDeduplicationStatus
(String topic) get deduplication enabled of a topic.TopicPolicies.getDeduplicationStatus
(String topic, boolean applied) get applied deduplication enabled of a topic.Topics.getDeduplicationStatus
(String topic) Deprecated.Topics.getDeduplicationStatus
(String topic, boolean applied) Deprecated.ResourceQuotas.getDefaultResourceQuota()
Get default resource quota for new resource bundles.Namespaces.getDelayedDelivery
(String namespace) Get the delayed delivery messages for all topics within a namespace.TopicPolicies.getDelayedDeliveryPolicy
(String topic) Get the delayed delivery policy for a specified topic.TopicPolicies.getDelayedDeliveryPolicy
(String topic, boolean applied) Get the delayed delivery policy applied for a specified topic.Topics.getDelayedDeliveryPolicy
(String topic) Deprecated.Topics.getDelayedDeliveryPolicy
(String topic, boolean applied) Deprecated.Namespaces.getDispatchRate
(String namespace) Get message-dispatch-rate (topics under this namespace can dispatch this many messages per second).TopicPolicies.getDispatchRate
(String topic) Get message-dispatch-rate (topic can dispatch this many messages per second).TopicPolicies.getDispatchRate
(String topic, boolean applied) Get applied message-dispatch-rate (topic can dispatch this many messages per second).Topics.getDispatchRate
(String topic) Deprecated.Topics.getDispatchRate
(String topic, boolean applied) Deprecated.Brokers.getDynamicConfigurationNames()
Get list of updatable configuration name.Namespaces.getEncryptionRequiredStatus
(String namespace) Get the encryption required status within a namespace.Clusters.getFailureDomain
(String cluster, String domainName) Get the domain registered into a cluster.Clusters.getFailureDomains
(String cluster) Get all registered domains in cluster.Functions.getFunction
(String tenant, String namespace, String function) Get the configuration for the specified function.Functions.getFunctions
(String tenant, String namespace) Get the list of functions.Worker.getFunctionsStats()
Get all functions stats on a worker.Functions.getFunctionState
(String tenant, String namespace, String function, String key) Fetch the current state associated with a Pulsar Function.Functions.getFunctionStats
(String tenant, String namespace, String function) Gets the current stats of a function.Functions.getFunctionStats
(String tenant, String namespace, String function, int id) Gets the current stats of a function instance.Functions.getFunctionStatus
(String tenant, String namespace, String function) Gets the current status of a function.Functions.getFunctionStatus
(String tenant, String namespace, String function, int id) Gets the current status of a function instance.Namespaces.getInactiveTopicPolicies
(String namespace) Get the inactive deletion strategy for all topics within a namespace synchronously.TopicPolicies.getInactiveTopicPolicies
(String topic) get inactive topic policies of a topic.TopicPolicies.getInactiveTopicPolicies
(String topic, boolean applied) Get inactive topic policies applied for a topic.Topics.getInactiveTopicPolicies
(String topic) Deprecated.Topics.getInactiveTopicPolicies
(String topic, boolean applied) Deprecated.Brokers.getInternalConfigurationData()
Get the internal configuration data.Topics.getInternalInfo
(String topic) Get a JSON representation of the topic metadata stored in ZooKeeper.NonPersistentTopics.getInternalStats
(String topic) Deprecated.Get the internal stats for the topic.Topics.getInternalStats
(String topic) Get the internal stats for the topic.Topics.getInternalStats
(String topic, boolean metadata) Get the internal stats for the topic.boolean
Namespaces.getIsAllowAutoUpdateSchema
(String namespace) Get whether allow auto update schema.org.apache.pulsar.client.api.MessageId
Topics.getLastMessageId
(String topic) Get the last commit message Id of a topic.Brokers.getLeaderBroker()
Get the information of the leader broker.Brokers.getLeaderBrokerAsync()
Get the service url of the leader broker asynchronously.Deprecated.Get list of topics exist into given namespace.Get the both persistent and non-persistent topics under a namespace.Topics.getList
(String namespace, TopicDomain topicDomain) Get the list of topics under a namespace.Topics.getList
(String namespace, TopicDomain topicDomain, Map<Topics.QueryParam, Object> params) Get the list of topics under a namespace.NonPersistentTopics.getListInBundle
(String namespace, String bundleRange) Deprecated.Get list of topics exist into given bundle.Topics.getListInBundle
(String namespace, String bundleRange) Get list of topics exist into given bundle.BrokerStats.getLoadReport()
Get load for this broker.TopicPolicies.getMaxConsumers
(String topic) Get the max number of consumer for specified topic.TopicPolicies.getMaxConsumers
(String topic, boolean applied) Get the max number of consumer applied for specified topic.Topics.getMaxConsumers
(String topic) Deprecated.Topics.getMaxConsumers
(String topic, boolean applied) Deprecated.Namespaces.getMaxConsumersPerSubscription
(String namespace) Get the maxConsumersPerSubscription for a namespace.TopicPolicies.getMaxConsumersPerSubscription
(String topic) Get the maxConsumersPerSubscription for a topic.Topics.getMaxConsumersPerSubscription
(String topic) Deprecated.Namespaces.getMaxConsumersPerTopic
(String namespace) Get the maxProducersPerTopic for a namespace.TopicPolicies.getMaxMessageSize
(String topic) Get the max message size for specified topic.Topics.getMaxMessageSize
(String topic) Deprecated.TopicPolicies.getMaxProducers
(String topic) Get the max number of producer for specified topic.TopicPolicies.getMaxProducers
(String topic, boolean applied) Get the max number of producer applied for specified topic.Topics.getMaxProducers
(String topic) Deprecated.Topics.getMaxProducers
(String topic, boolean applied) Deprecated.Namespaces.getMaxProducersPerTopic
(String namespace) Get the maxProducersPerTopic for a namespace.Namespaces.getMaxSubscriptionsPerTopic
(String namespace) Get the maxSubscriptionsPerTopic for a namespace.TopicPolicies.getMaxSubscriptionsPerTopic
(String topic) Get the max number of subscriptions for specified topic.Topics.getMaxSubscriptionsPerTopic
(String topic) Deprecated.int
Namespaces.getMaxTopicsPerNamespace
(String namespace) Get maxTopicsPerNamespace for a namespace.TopicPolicies.getMaxUnackedMessagesOnConsumer
(String topic) Get max unacked messages on a consumer of a topic.TopicPolicies.getMaxUnackedMessagesOnConsumer
(String topic, boolean applied) get applied max unacked messages on consumer of a topic.Topics.getMaxUnackedMessagesOnConsumer
(String topic) Deprecated.Topics.getMaxUnackedMessagesOnConsumer
(String topic, boolean applied) Deprecated.TopicPolicies.getMaxUnackedMessagesOnSubscription
(String topic) get max unacked messages on subscription of a topic.TopicPolicies.getMaxUnackedMessagesOnSubscription
(String topic, boolean applied) get max unacked messages on subscription of a topic.Topics.getMaxUnackedMessagesOnSubscription
(String topic) Deprecated.Topics.getMaxUnackedMessagesOnSubscription
(String topic, boolean applied) Deprecated.Namespaces.getMaxUnackedMessagesPerConsumer
(String namespace) Get the maxUnackedMessagesPerConsumer for a namespace.Namespaces.getMaxUnackedMessagesPerSubscription
(String namespace) Get the maxUnackedMessagesPerSubscription for a namespace.BrokerStats.getMBeans()
Requests JSON string server mbean dump.org.apache.pulsar.client.api.Message<byte[]>
Topics.getMessageById
(String topic, long ledgerId, long entryId) Get a message by its messageId via a topic subscription.org.apache.pulsar.client.api.MessageId
Topics.getMessageIdByTimestamp
(String topic, long timestamp) Get message ID published at or just after this absolute timestamp (in ms).TopicPolicies.getMessageTTL
(String topic) Get message TTL for a topic.TopicPolicies.getMessageTTL
(String topic, boolean applied) Get message TTL applied for a topic.Topics.getMessageTTL
(String topic) Deprecated.Topics.getMessageTTL
(String topic, boolean applied) Deprecated.Packages.getMetadata
(String packageName) Get a package metadata information.BrokerStats.getMetrics()
Returns Monitoring metrics.Worker.getMetrics()
Get worker metrics.Namespaces.getNamespaceAntiAffinityGroup
(String namespace) Get anti-affinity group name for a namespace.ResourceQuotas.getNamespaceBundleResourceQuota
(String namespace, String bundle) Get resource quota of a namespace bundle.Clusters.getNamespaceIsolationPolicies
(String cluster) Get the namespace isolation policies of a cluster.Clusters.getNamespaceIsolationPolicy
(String cluster, String policyName) Get a single namespace isolation policy for a cluster.Namespaces.getNamespaceMessageTTL
(String namespace) Get the message TTL for a namespace.Namespaces.getNamespaceReplicationClusters
(String namespace) Get the replication clusters for a namespace.Namespaces.getNamespaceResourceGroup
(String namespace) Get the ResourceGroup for a namespace.Namespaces.getNamespaces
(String tenant) Get the list of namespaces.Namespaces.getNamespaces
(String tenant, String cluster) Deprecated.Namespaces.getOffloadDeleteLagMs
(String namespace) Get the offload deletion lag for a namespace, in milliseconds.Namespaces.getOffloadPolicies
(String namespace) Get the offload configuration for a namespace.TopicPolicies.getOffloadPolicies
(String topic) get offload policies of a topic.TopicPolicies.getOffloadPolicies
(String topic, boolean applied) get applied offload policies of a topic.Topics.getOffloadPolicies
(String topic) Deprecated.Topics.getOffloadPolicies
(String topic, boolean applied) Deprecated.long
Namespaces.getOffloadThreshold
(String namespace) Get the offloadThreshold for a namespace.Brokers.getOwnedNamespaces
(String cluster, String brokerUrl) Get the map of owned namespaces and their status from a single broker in the cluster.Topics.getPartitionedInternalStats
(String topic) Get the stats for the partitioned topic.default PartitionedTopicStats
Topics.getPartitionedStats
(String topic, boolean perPartition) Topics.getPartitionedStats
(String topic, boolean perPartition, boolean getPreciseBacklog, boolean subscriptionBacklogSize) Get the stats for the partitioned topicTopics.getPartitionedTopicList
(String namespace) Get the list of partitioned topics under a namespace.NonPersistentTopics.getPartitionedTopicMetadata
(String topic) Deprecated.Get metadata of a partitioned topic.Topics.getPartitionedTopicMetadata
(String topic) Get metadata of a partitioned topic.Clusters.getPeerClusterNames
(String cluster) Get peer-cluster names.Transactions.getPendingAckInternalStats
(String topic, String subName, boolean metadata) Get pending ack internal stats.Transactions.getPendingAckStats
(String topic, String subName) Get transaction pending ack stats.BrokerStats.getPendingBookieOpsStats()
Get pending bookie client op stats by namespace.Namespaces.getPermissionOnSubscription
(String namespace) Get permission to role to access subscription's admin-api.Namespaces.getPermissions
(String namespace) Get permissions on a namespace.Topics.getPermissions
(String topic) Get permissions on a topic.Namespaces.getPersistence
(String namespace) Get the persistence configuration for a namespace.TopicPolicies.getPersistence
(String topic) Get the configuration of persistence policies for specified topic.TopicPolicies.getPersistence
(String topic, boolean applied) Get the applied configuration of persistence policies for specified topic.Topics.getPersistence
(String topic) Deprecated.Topics.getPersistence
(String topic, boolean applied) Deprecated.Namespaces.getPolicies
(String namespace) Get policies for a namespace.Namespaces.getProperties
(String namespace) Get all properties of a namespace.Properties.getProperties()
Deprecated.Get the list of properties.Topics.getProperties
(String topic) Get properties of a topic.Namespaces.getProperty
(String namespace, String key) Get property value for a given key.Properties.getPropertyAdmin
(String property) Deprecated.Get the config of the property.Namespaces.getPublishRate
(String namespace) Get message-publish-rate (topics under this namespace can publish this many messages per second).TopicPolicies.getPublishRate
(String topic) Get message-publish-rate (topics can publish this many messages per second).Topics.getPublishRate
(String topic) Deprecated.Topics.getReplicatedSubscriptionStatus
(String topic, String subName) Get replicated subscription status on a topic.Topics.getReplicationClusters
(String topic, boolean applied) Get the replication clusters for a topic.Namespaces.getReplicationConfigVersion
(String namespace) Get the replication configuration version for a given namespace.Namespaces.getReplicatorDispatchRate
(String namespace) Get replicator-message-dispatch-rate.TopicPolicies.getReplicatorDispatchRate
(String topic) Get replicatorDispatchRate for the topic.TopicPolicies.getReplicatorDispatchRate
(String topic, boolean applied) Get applied replicatorDispatchRate for the topic.Topics.getReplicatorDispatchRate
(String topic) Deprecated.Topics.getReplicatorDispatchRate
(String topic, boolean applied) Deprecated.ResourceGroups.getResourceGroup
(String resourcegroup) Get configuration for a resourcegroup.ResourceGroups.getResourceGroups()
Get the list of resourcegroups.Namespaces.getRetention
(String namespace) Get the retention configuration for a namespace.TopicPolicies.getRetention
(String topic) Get the retention configuration for a topic.TopicPolicies.getRetention
(String topic, boolean applied) Get the applied retention configuration for a topic.Topics.getRetention
(String topic) Deprecated.Topics.getRetention
(String topic, boolean applied) Deprecated.Brokers.getRuntimeConfigurations()
Get values of runtime configuration.Namespaces.getSchemaAutoUpdateCompatibilityStrategy
(String namespace) Deprecated.Namespaces.getSchemaCompatibilityStrategy
(String namespace) Get the strategy used to check the a new schema provided by a producer is compatible with the current schema before it is installed.TopicPolicies.getSchemaCompatibilityStrategy
(String topic, boolean applied) Get schema compatibility strategy on a topic.org.apache.pulsar.common.schema.SchemaInfo
Schemas.getSchemaInfo
(String topic) Retrieve the latest schema of a topic.org.apache.pulsar.common.schema.SchemaInfo
Schemas.getSchemaInfo
(String topic, long version) Retrieve the schema of a topic at a given version.org.apache.pulsar.common.schema.SchemaInfoWithVersion
Schemas.getSchemaInfoWithVersion
(String topic) Retrieve the latest schema with verison of a topic.boolean
Namespaces.getSchemaValidationEnforced
(String namespace) Get schema validation enforced for namespace.boolean
Namespaces.getSchemaValidationEnforced
(String namespace, boolean applied) Get schema validation enforced for namespace.Get the configuration for the specified sink.Functions.getSinks()
Deprecated.Sinks.getSinkStatus
(String tenant, String namespace, String sink) Gets the current status of a sink.Sinks.getSinkStatus
(String tenant, String namespace, String sink, int id) Gets the current status of a sink instance.Transactions.getSlowTransactions
(long timeout, TimeUnit timeUnit) Get slow transactions.Transactions.getSlowTransactionsByCoordinatorId
(Integer coordinatorId, long timeout, TimeUnit timeUnit) Get slow transactions by coordinator id.Get the configuration for the specified source.Functions.getSources()
Deprecated.Sources.getSourceStatus
(String tenant, String namespace, String source) Gets the current status of a source.Sources.getSourceStatus
(String tenant, String namespace, String source, int id) Gets the current status of a source instance.Deprecated.Get the stats for the topic.default TopicStats
default TopicStats
default TopicStats
default TopicStats
Topics.getStats
(String topic, boolean getPreciseBacklog, boolean subscriptionBacklogSize, boolean getEarliestTimeInBacklog) Topics.getStats
(String topic, GetStatsOptions getStatsOptions) Get the stats for the topic.Namespaces.getSubscribeRate
(String namespace) Get namespace-subscribe-rate (topics under this namespace allow subscribe times per consumer in a period).TopicPolicies.getSubscribeRate
(String topic) Get topic-subscribe-rate (topics allow subscribe times per consumer in a period).TopicPolicies.getSubscribeRate
(String topic, boolean applied) Get applied topic-subscribe-rate (topics allow subscribe times per consumer in a period).Topics.getSubscribeRate
(String topic) Deprecated.Topics.getSubscribeRate
(String topic, boolean applied) Deprecated.Namespaces.getSubscriptionAuthMode
(String namespace) Get the subscriptionAuthMode within a namespace.Namespaces.getSubscriptionDispatchRate
(String namespace) Get subscription-message-dispatch-rate.TopicPolicies.getSubscriptionDispatchRate
(String topic) Get subscription-message-dispatch-rate for the topic.TopicPolicies.getSubscriptionDispatchRate
(String topic, boolean applied) Get applied subscription-message-dispatch-rate.Topics.getSubscriptionDispatchRate
(String topic) Deprecated.Topics.getSubscriptionDispatchRate
(String namespace, boolean applied) Deprecated.Namespaces.getSubscriptionExpirationTime
(String namespace) Get the subscription expiration time for a namespace.Topics.getSubscriptions
(String topic) Get the list of subscriptions.Set<org.apache.pulsar.client.api.SubscriptionType>
Namespaces.getSubscriptionTypesEnabled
(String namespace) Get the subscriptionTypesEnabled policy for a given namespace, overriding broker settings.Set<org.apache.pulsar.client.api.SubscriptionType>
TopicPolicies.getSubscriptionTypesEnabled
(String topic) Get is enable sub types.Set<org.apache.pulsar.client.api.SubscriptionType>
Topics.getSubscriptionTypesEnabled
(String topic) Deprecated.Tenants.getTenantInfo
(String tenant) Get the config of the tenant.Tenants.getTenants()
Get the list of tenants.BrokerStats.getTopics()
Returns JSON string topics stats.Get the list of topics.ProxyStats.getTopics()
Returns Topics metrics.Transactions.getTransactionBufferStats
(String topic) Get transaction buffer stats.Transactions.getTransactionInBufferStats
(org.apache.pulsar.client.api.transaction.TxnID txnID, String topic) Get transaction in buffer stats.Transactions.getTransactionInPendingAckStats
(org.apache.pulsar.client.api.transaction.TxnID txnID, String topic, String subName) Get transaction in pending ack stats.Transactions.getTransactionMetadata
(org.apache.pulsar.client.api.transaction.TxnID txnID) Get transaction metadata.Brokers.getVersion()
Get version of broker.Schemas.getVersionBySchema
(String topic, PostSchemaPayload schemaPayload) Find schema version topic.Schemas.getVersionBySchema
(String topic, org.apache.pulsar.common.schema.SchemaInfo schemaInfo) Find schema version topic.void
Topics.grantPermission
(String topic, String role, Set<AuthAction> actions) Grant permission on a topic.void
Namespaces.grantPermissionOnNamespace
(String namespace, String role, Set<AuthAction> actions) Grant permission on a namespace.void
Namespaces.grantPermissionOnSubscription
(String namespace, String subscription, Set<String> roles) Grant permission to role to access subscription's admin-api.void
Brokers.healthcheck()
Deprecated.void
Brokers.healthcheck
(TopicVersion topicVersion) Run a healthcheck on the broker.Packages.listPackages
(String type, String namespace) List all the packages with the given type in a namespace.Packages.listPackageVersions
(String packageName) List all the versions of a package.Get the list of sinks.Sources.listSources
(String tenant, String namespace) Get the list of sources.Lookup.lookupPartitionedTopic
(String topic) Lookup a partitioned topic.Lookup.lookupTopic
(String topic) Lookup a topic.Topics.offloadStatus
(String topic) Check the status of an ongoing offloading operation for a topic.List<org.apache.pulsar.client.api.Message<byte[]>>
Topics.peekMessages
(String topic, String subName, int numMessages) Peek messages from a topic subscription.void
Functions.putFunctionState
(String tenant, String namespace, String function, FunctionState state) Puts the given state associated with a Pulsar Function.void
Worker.rebalance()
Triggers a rebalance of functions to workers.void
Sinks.reloadBuiltInSinks()
Reload the available built-in connectors, include Source and Sink.void
Sources.reloadBuiltInSources()
Reload the available built-in connectors, include Source and Source.void
Namespaces.removeAutoSubscriptionCreation
(String namespace) Removes the autoSubscriptionCreation policy for a given namespace.void
Namespaces.removeAutoTopicCreation
(String namespace) Removes the autoTopicCreation policy for a given namespace.default void
Namespaces.removeBacklogQuota
(String namespace) void
Namespaces.removeBacklogQuota
(String namespace, BacklogQuota.BacklogQuotaType backlogQuotaType) Remove a backlog quota policy from a namespace.default void
TopicPolicies.removeBacklogQuota
(String topic) void
TopicPolicies.removeBacklogQuota
(String topic, BacklogQuota.BacklogQuotaType backlogQuotaType) Remove a backlog quota policy from a topic.default void
Topics.removeBacklogQuota
(String topic) Deprecated.void
Topics.removeBacklogQuota
(String topic, BacklogQuota.BacklogQuotaType backlogQuotaType) Deprecated.void
Namespaces.removeCompactionThreshold
(String namespace) Delete the compactionThreshold for a namespace.void
TopicPolicies.removeCompactionThreshold
(String topic) Remove the compactionThreshold for a topic.void
Topics.removeCompactionThreshold
(String topic) Deprecated.void
Namespaces.removeDeduplicationSnapshotInterval
(String namespace) Remove the deduplicationSnapshotInterval for a namespace.void
TopicPolicies.removeDeduplicationSnapshotInterval
(String topic) Remove the deduplication snapshot interval for specified topic.void
Topics.removeDeduplicationSnapshotInterval
(String topic) Deprecated.void
Namespaces.removeDeduplicationStatus
(String namespace) Remove the deduplication status for all topics within a namespace.void
TopicPolicies.removeDeduplicationStatus
(String topic) remove deduplication enabled of a topic.void
Topics.removeDeduplicationStatus
(String topic) Deprecated.void
Namespaces.removeDelayedDeliveryMessages
(String namespace) Remove the delayed delivery messages for all topics within a namespace.void
TopicPolicies.removeDelayedDeliveryPolicy
(String topic) Remove the delayed delivery policy for a specified topic.void
Topics.removeDelayedDeliveryPolicy
(String topic) Deprecated.void
Namespaces.removeDispatchRate
(String namespace) Remove message-dispatch-rate.void
TopicPolicies.removeDispatchRate
(String topic) Remove message-dispatch-rate.void
Topics.removeDispatchRate
(String topic) Deprecated.TopicPolicies.removeDispatchRateAsync
(String topic) Remove message-dispatch-rate asynchronously.Topics.removeDispatchRateAsync
(String topic) Deprecated.void
Namespaces.removeInactiveTopicPolicies
(String namespace) Remove inactive topic policies from a namespace.void
TopicPolicies.removeInactiveTopicPolicies
(String topic) remove inactive topic policies of a topic.void
Topics.removeInactiveTopicPolicies
(String topic) Deprecated.void
TopicPolicies.removeMaxConsumers
(String topic) Remove the max number of consumer for specified topic.void
Topics.removeMaxConsumers
(String topic) Deprecated.void
Namespaces.removeMaxConsumersPerSubscription
(String namespace) Remove maxConsumersPerSubscription for a namespace.void
TopicPolicies.removeMaxConsumersPerSubscription
(String topic) Remove the maxConsumersPerSubscription for a topic.void
Topics.removeMaxConsumersPerSubscription
(String topic) Deprecated.void
Namespaces.removeMaxConsumersPerTopic
(String namespace) Remove maxConsumersPerTopic for a namespace.void
TopicPolicies.removeMaxMessageSize
(String topic) Remove the max message size for specified topic.void
Topics.removeMaxMessageSize
(String topic) Deprecated.void
TopicPolicies.removeMaxProducers
(String topic) Remove the max number of producer for specified topic.void
Topics.removeMaxProducers
(String topic) Deprecated.void
Namespaces.removeMaxProducersPerTopic
(String namespace) Remove maxProducersPerTopic for a namespace.void
Namespaces.removeMaxSubscriptionsPerTopic
(String namespace) Remove the maxSubscriptionsPerTopic for a namespace.void
TopicPolicies.removeMaxSubscriptionsPerTopic
(String topic) Remove the max number of subscriptions for specified topic.void
Topics.removeMaxSubscriptionsPerTopic
(String topic) Deprecated.void
Namespaces.removeMaxTopicsPerNamespace
(String namespace) remove maxTopicsPerNamespace for a namespace.void
TopicPolicies.removeMaxUnackedMessagesOnConsumer
(String topic) remove max unacked messages on consumer of a topic.void
Topics.removeMaxUnackedMessagesOnConsumer
(String topic) Deprecated.void
TopicPolicies.removeMaxUnackedMessagesOnSubscription
(String topic) remove max unacked messages on subscription of a topic.void
Topics.removeMaxUnackedMessagesOnSubscription
(String topic) Deprecated.void
Namespaces.removeMaxUnackedMessagesPerConsumer
(String namespace) Remove maxUnackedMessagesPerConsumer for a namespace.void
Namespaces.removeMaxUnackedMessagesPerSubscription
(String namespace) Remove maxUnackedMessagesPerSubscription for a namespace.void
TopicPolicies.removeMessageTTL
(String topic) Remove message TTL for a topic.void
Topics.removeMessageTTL
(String topic) Deprecated.void
Namespaces.removeNamespaceMessageTTL
(String namespace) Remove the messages Time to Live for all the topics within a namespace.void
Namespaces.removeNamespaceResourceGroup
(String namespace) Remove the ResourceGroup on a namespace.void
Namespaces.removeOffloadPolicies
(String namespace) Remove the offload configuration for a namespace.void
TopicPolicies.removeOffloadPolicies
(String topic) remove offload policies of a topic.void
Topics.removeOffloadPolicies
(String topic) Deprecated.void
Namespaces.removePersistence
(String namespace) Remove the persistence configuration on a namespace.void
TopicPolicies.removePersistence
(String topic) Remove the configuration of persistence policies for specified topic.void
Topics.removePersistence
(String topic) Deprecated.Namespaces.removeProperty
(String namespace, String key) Remove a property for a given key.void
Namespaces.removePublishRate
(String namespace) Remove message-publish-rate (topics under this namespace can publish this many messages per second).void
TopicPolicies.removePublishRate
(String topic) Remove message-publish-rate.void
Topics.removePublishRate
(String topic) Deprecated.TopicPolicies.removePublishRateAsync
(String topic) Remove message-publish-rate asynchronously.Topics.removePublishRateAsync
(String topic) Deprecated.void
Topics.removeReplicationClusters
(String topic) Remove the replication clusters for the topic.void
Namespaces.removeReplicatorDispatchRate
(String namespace) Remove replicator-message-dispatch-rate.void
TopicPolicies.removeReplicatorDispatchRate
(String topic) Remove replicatorDispatchRate for a topic.void
Topics.removeReplicatorDispatchRate
(String topic) Deprecated.void
Namespaces.removeRetention
(String namespace) Remove the retention configuration for all the topics on a namespace.void
TopicPolicies.removeRetention
(String topic) Remove the retention configuration for all the topics on a topic.void
Topics.removeRetention
(String topic) Deprecated.void
TopicPolicies.removeSchemaCompatibilityStrategy
(String topic) Remove schema compatibility strategy on a topic.void
Namespaces.removeSubscribeRate
(String namespace) Remove namespace-subscribe-rate (topics under this namespace will limit by subscribeRate).void
TopicPolicies.removeSubscribeRate
(String topic) Remove topic-subscribe-rate.void
Topics.removeSubscribeRate
(String topic) Deprecated.TopicPolicies.removeSubscribeRateAsync
(String topic) Remove topic-subscribe-rate asynchronously.Topics.removeSubscribeRateAsync
(String topic) Deprecated.void
Namespaces.removeSubscriptionDispatchRate
(String namespace) Remove subscription-message-dispatch-rate.void
TopicPolicies.removeSubscriptionDispatchRate
(String topic) Remove subscription-message-dispatch-rate for a topic.void
Topics.removeSubscriptionDispatchRate
(String topic) Deprecated.void
Namespaces.removeSubscriptionExpirationTime
(String namespace) Remove the subscription expiration time for a namespace.void
Namespaces.removeSubscriptionTypesEnabled
(String namespace) Removes the subscriptionTypesEnabled policy for a given namespace.void
TopicPolicies.removeSubscriptionTypesEnabled
(String topic) Remove subscription types enabled for a topic.void
Topics.removeSubscriptionTypesEnabled
(String topic) Deprecated.void
Topics.resetCursor
(String topic, String subName, long timestamp) Reset cursor position on a topic subscription.void
Topics.resetCursor
(String topic, String subName, org.apache.pulsar.client.api.MessageId messageId) Reset cursor position on a topic subscription.void
Topics.resetCursor
(String topic, String subName, org.apache.pulsar.client.api.MessageId messageId, boolean isExcluded) Reset cursor position on a topic subscription.void
ResourceQuotas.resetNamespaceBundleResourceQuota
(String namespace, String bundle) Reset resource quota for a namespace bundle to default value.void
Functions.restartFunction
(String tenant, String namespace, String function) Restart all function instances.void
Functions.restartFunction
(String tenant, String namespace, String function, int instanceId) Restart function instance.void
Sinks.restartSink
(String tenant, String namespace, String sink) Restart all sink instances.void
Sinks.restartSink
(String tenant, String namespace, String sink, int instanceId) Restart sink instance.void
Sources.restartSource
(String tenant, String namespace, String source) Restart all source instances.void
Sources.restartSource
(String tenant, String namespace, String source, int instanceId) Restart source instance.void
Namespaces.revokePermissionOnSubscription
(String namespace, String subscription, String role) Revoke permissions on a subscription's admin-api access.void
Topics.revokePermissions
(String topic, String role) Revoke permissions on a topic.void
Namespaces.revokePermissionsOnNamespace
(String namespace, String role) Revoke permissions on a namespace.void
Namespaces.setAutoSubscriptionCreation
(String namespace, AutoSubscriptionCreationOverride autoSubscriptionCreationOverride) Sets the autoSubscriptionCreation policy for a given namespace, overriding broker settings.void
Namespaces.setAutoTopicCreation
(String namespace, AutoTopicCreationOverride autoTopicCreationOverride) Sets the autoTopicCreation policy for a given namespace, overriding broker settings.default void
Namespaces.setBacklogQuota
(String namespace, BacklogQuota backlogQuota) void
Namespaces.setBacklogQuota
(String namespace, BacklogQuota backlogQuota, BacklogQuota.BacklogQuotaType backlogQuotaType) Set a backlog quota for all the topics on a namespace.default void
TopicPolicies.setBacklogQuota
(String topic, BacklogQuota backlogQuota) void
TopicPolicies.setBacklogQuota
(String topic, BacklogQuota backlogQuota, BacklogQuota.BacklogQuotaType backlogQuotaType) Set a backlog quota for a topic.default void
Topics.setBacklogQuota
(String topic, BacklogQuota backlogQuota) Deprecated.void
Topics.setBacklogQuota
(String topic, BacklogQuota backlogQuota, BacklogQuota.BacklogQuotaType backlogQuotaType) Deprecated.void
Namespaces.setBookieAffinityGroup
(String namespace, BookieAffinityGroupData bookieAffinityGroup) Set bookie affinity group for a namespace to isolate namespace write to bookies that are part of given affinity group.void
Namespaces.setCompactionThreshold
(String namespace, long compactionThreshold) Set the compactionThreshold for a namespace.void
TopicPolicies.setCompactionThreshold
(String topic, long compactionThreshold) Set the compactionThreshold for a topic.void
Topics.setCompactionThreshold
(String topic, long compactionThreshold) Deprecated.void
Namespaces.setDeduplicationSnapshotInterval
(String namespace, Integer interval) Set the deduplicationSnapshotInterval for a namespace.void
TopicPolicies.setDeduplicationSnapshotInterval
(String topic, int interval) Set the deduplication snapshot interval for specified topic.void
Topics.setDeduplicationSnapshotInterval
(String topic, int interval) Deprecated.void
Namespaces.setDeduplicationStatus
(String namespace, boolean enableDeduplication) Set the deduplication status for all topics within a namespace.void
TopicPolicies.setDeduplicationStatus
(String topic, boolean enabled) set deduplication enabled of a topic.void
Topics.setDeduplicationStatus
(String topic, boolean enabled) Deprecated.void
ResourceQuotas.setDefaultResourceQuota
(ResourceQuota quota) Set default resource quota for new namespace bundles.void
Namespaces.setDelayedDeliveryMessages
(String namespace, DelayedDeliveryPolicies delayedDeliveryPolicies) Set the delayed delivery messages for all topics within a namespace.void
TopicPolicies.setDelayedDeliveryPolicy
(String topic, DelayedDeliveryPolicies delayedDeliveryPolicies) Set the delayed delivery policy for a specified topic.void
Topics.setDelayedDeliveryPolicy
(String topic, DelayedDeliveryPolicies delayedDeliveryPolicies) Deprecated.void
Namespaces.setDispatchRate
(String namespace, DispatchRate dispatchRate) Set message-dispatch-rate (topics under this namespace can dispatch this many messages per second).void
TopicPolicies.setDispatchRate
(String topic, DispatchRate dispatchRate) Set message-dispatch-rate (topic can dispatch this many messages per second).void
Topics.setDispatchRate
(String topic, DispatchRate dispatchRate) Deprecated.void
Namespaces.setEncryptionRequiredStatus
(String namespace, boolean encryptionRequired) Set the encryption required status for all topics within a namespace.void
Namespaces.setInactiveTopicPolicies
(String namespace, InactiveTopicPolicies inactiveTopicPolicies) As same as setInactiveTopicPoliciesAsync,but it is synchronous.void
TopicPolicies.setInactiveTopicPolicies
(String topic, InactiveTopicPolicies inactiveTopicPolicies) set inactive topic policies of a topic.void
Topics.setInactiveTopicPolicies
(String topic, InactiveTopicPolicies inactiveTopicPolicies) Deprecated.void
Namespaces.setIsAllowAutoUpdateSchema
(String namespace, boolean isAllowAutoUpdateSchema) Set whether to allow automatic schema updates.void
TopicPolicies.setMaxConsumers
(String topic, int maxConsumers) Set the max number of consumer for specified topic.void
Topics.setMaxConsumers
(String topic, int maxConsumers) Deprecated.void
Namespaces.setMaxConsumersPerSubscription
(String namespace, int maxConsumersPerSubscription) Set maxConsumersPerSubscription for a namespace.void
TopicPolicies.setMaxConsumersPerSubscription
(String topic, int maxConsumersPerSubscription) Set maxConsumersPerSubscription for a topic.void
Topics.setMaxConsumersPerSubscription
(String topic, int maxConsumersPerSubscription) Deprecated.void
Namespaces.setMaxConsumersPerTopic
(String namespace, int maxConsumersPerTopic) Set maxConsumersPerTopic for a namespace.void
TopicPolicies.setMaxMessageSize
(String topic, int maxMessageSize) Set the max message size for specified topic.void
Topics.setMaxMessageSize
(String topic, int maxMessageSize) Deprecated.void
TopicPolicies.setMaxProducers
(String topic, int maxProducers) Set the max number of producer for specified topic.void
Topics.setMaxProducers
(String topic, int maxProducers) Deprecated.void
Namespaces.setMaxProducersPerTopic
(String namespace, int maxProducersPerTopic) Set maxProducersPerTopic for a namespace.void
Namespaces.setMaxSubscriptionsPerTopic
(String namespace, int maxSubscriptionsPerTopic) Set the maxSubscriptionsPerTopic for a namespace.void
TopicPolicies.setMaxSubscriptionsPerTopic
(String topic, int maxSubscriptionsPerTopic) Set the max number of subscriptions for specified topic.void
Topics.setMaxSubscriptionsPerTopic
(String topic, int maxSubscriptionsPerTopic) Deprecated.void
Namespaces.setMaxTopicsPerNamespace
(String namespace, int maxTopicsPerNamespace) Set maxTopicsPerNamespace for a namespace.void
TopicPolicies.setMaxUnackedMessagesOnConsumer
(String topic, int maxNum) set max unacked messages on consumer of a topic.void
Topics.setMaxUnackedMessagesOnConsumer
(String topic, int maxNum) Deprecated.void
TopicPolicies.setMaxUnackedMessagesOnSubscription
(String topic, int maxNum) set max unacked messages on subscription of a topic.void
Topics.setMaxUnackedMessagesOnSubscription
(String topic, int maxNum) Deprecated.void
Namespaces.setMaxUnackedMessagesPerConsumer
(String namespace, int maxUnackedMessagesPerConsumer) Set maxUnackedMessagesPerConsumer for a namespace.void
Namespaces.setMaxUnackedMessagesPerSubscription
(String namespace, int maxUnackedMessagesPerSubscription) Set maxUnackedMessagesPerSubscription for a namespace.void
TopicPolicies.setMessageTTL
(String topic, int messageTTLInSecond) Set message TTL for a topic.void
Topics.setMessageTTL
(String topic, int messageTTLInSecond) Deprecated.void
Namespaces.setNamespaceAntiAffinityGroup
(String namespace, String namespaceAntiAffinityGroup) Set anti-affinity group name for a namespace.void
ResourceQuotas.setNamespaceBundleResourceQuota
(String namespace, String bundle, ResourceQuota quota) Set resource quota for a namespace bundle.void
Namespaces.setNamespaceMessageTTL
(String namespace, int ttlInSeconds) Set the messages Time to Live for all the topics within a namespace.void
Namespaces.setNamespaceReplicationClusters
(String namespace, Set<String> clusterIds) Set the replication clusters for a namespace.void
Namespaces.setNamespaceResourceGroup
(String namespace, String resourcegroupname) Set the ResourceGroup for a namespace.void
Namespaces.setOffloadDeleteLag
(String namespace, long lag, TimeUnit unit) Set the offload deletion lag for a namespace.void
Namespaces.setOffloadPolicies
(String namespace, OffloadPolicies offloadPolicies) Set the offload configuration for all the topics in a namespace.void
TopicPolicies.setOffloadPolicies
(String topic, OffloadPolicies offloadPolicies) set offload policies of a topic.void
Topics.setOffloadPolicies
(String topic, OffloadPolicies offloadPolicies) Deprecated.void
Namespaces.setOffloadThreshold
(String namespace, long offloadThreshold) Set the offloadThreshold for a namespace.void
Namespaces.setPersistence
(String namespace, PersistencePolicies persistence) Set the persistence configuration for all the topics on a namespace.void
TopicPolicies.setPersistence
(String topic, PersistencePolicies persistencePolicies) Set the configuration of persistence policies for specified topic.void
Topics.setPersistence
(String topic, PersistencePolicies persistencePolicies) Deprecated.void
Namespaces.setProperties
(String namespace, Map<String, String> properties) Set key value pair properties for a namespace.void
Namespaces.setProperty
(String namespace, String key, String value) Set key value pair property for a namespace.void
Namespaces.setPublishRate
(String namespace, PublishRate publishMsgRate) Set message-publish-rate (topics under this namespace can publish this many messages per second).void
TopicPolicies.setPublishRate
(String topic, PublishRate publishMsgRate) Set message-publish-rate (topics can publish this many messages per second).void
Topics.setPublishRate
(String topic, PublishRate publishMsgRate) Deprecated.void
Topics.setReplicatedSubscriptionStatus
(String topic, String subName, boolean enabled) Enable or disable a replicated subscription on a topic.void
Topics.setReplicationClusters
(String topic, List<String> clusterIds) Set the replication clusters for the topic.void
Namespaces.setReplicatorDispatchRate
(String namespace, DispatchRate dispatchRate) Set replicator-message-dispatch-rate.void
TopicPolicies.setReplicatorDispatchRate
(String topic, DispatchRate dispatchRate) Set replicatorDispatchRate for the topic.void
Topics.setReplicatorDispatchRate
(String topic, DispatchRate dispatchRate) Deprecated.void
Namespaces.setRetention
(String namespace, RetentionPolicies retention) Set the retention configuration for all the topics on a namespace.void
TopicPolicies.setRetention
(String topic, RetentionPolicies retention) Set the retention configuration on a topic.void
Topics.setRetention
(String topic, RetentionPolicies retention) Deprecated.void
Namespaces.setSchemaAutoUpdateCompatibilityStrategy
(String namespace, SchemaAutoUpdateCompatibilityStrategy strategy) Deprecated.void
Namespaces.setSchemaCompatibilityStrategy
(String namespace, SchemaCompatibilityStrategy strategy) Set the strategy used to check the a new schema provided by a producer is compatible with the current schema before it is installed.void
TopicPolicies.setSchemaCompatibilityStrategy
(String topic, SchemaCompatibilityStrategy strategy) Set schema compatibility strategy on a topic.void
Namespaces.setSchemaValidationEnforced
(String namespace, boolean schemaValidationEnforced) Set schema validation enforced for namespace.void
Namespaces.setSubscribeRate
(String namespace, SubscribeRate subscribeRate) Set namespace-subscribe-rate (topics under this namespace will limit by subscribeRate).void
TopicPolicies.setSubscribeRate
(String topic, SubscribeRate subscribeRate) Set topic-subscribe-rate (topic will limit by subscribeRate).void
Topics.setSubscribeRate
(String topic, SubscribeRate subscribeRate) Deprecated.void
Namespaces.setSubscriptionAuthMode
(String namespace, SubscriptionAuthMode subscriptionAuthMode) Set the given subscription auth mode on all topics on a namespace.void
Namespaces.setSubscriptionDispatchRate
(String namespace, DispatchRate dispatchRate) Set subscription-message-dispatch-rate.void
TopicPolicies.setSubscriptionDispatchRate
(String topic, DispatchRate dispatchRate) Set subscription-message-dispatch-rate for the topic.void
Topics.setSubscriptionDispatchRate
(String topic, DispatchRate dispatchRate) Deprecated.void
Namespaces.setSubscriptionExpirationTime
(String namespace, int expirationTime) Set the subscription expiration time in minutes for all the topics within a namespace.void
Namespaces.setSubscriptionTypesEnabled
(String namespace, Set<org.apache.pulsar.client.api.SubscriptionType> subscriptionTypesEnabled) Sets the subscriptionTypesEnabled policy for a given namespace, overriding broker settings.void
TopicPolicies.setSubscriptionTypesEnabled
(String topic, Set<org.apache.pulsar.client.api.SubscriptionType> subscriptionTypesEnabled) Set is enable sub types.void
Topics.setSubscriptionTypesEnabled
(String topic, Set<org.apache.pulsar.client.api.SubscriptionType> subscriptionTypesEnabled) Deprecated.void
Topics.skipAllMessages
(String topic, String subName) Skip all messages on a topic subscription.void
Topics.skipMessages
(String topic, String subName, long numMessages) Skip messages on a topic subscription.void
Namespaces.splitNamespaceBundle
(String namespace, String bundle, boolean unloadSplitBundles, String splitAlgorithmName) Split namespace bundle.void
Functions.startFunction
(String tenant, String namespace, String function) Start all function instances.void
Functions.startFunction
(String tenant, String namespace, String function, int instanceId) Start function instance.void
Start all sink instances.void
Start sink instance.void
Sources.startSource
(String tenant, String namespace, String source) Start all source instances.void
Sources.startSource
(String tenant, String namespace, String source, int instanceId) Start source instance.void
Functions.stopFunction
(String tenant, String namespace, String function) Stop all function instances.void
Functions.stopFunction
(String tenant, String namespace, String function, int instanceId) Stop function instance.void
Stop all sink instances.void
Stop sink instance.void
Sources.stopSource
(String tenant, String namespace, String source) Stop all source instances.void
Sources.stopSource
(String tenant, String namespace, String source, int instanceId) Stop source instance.Topics.terminatePartitionedTopic
(String topic) Terminate the partitioned topic and prevent any more messages being published on it.org.apache.pulsar.client.api.MessageId
Topics.terminateTopic
(String topic) Terminate the topic and prevent any more messages being published on it.Schemas.testCompatibility
(String topic, PostSchemaPayload schemaPayload) Judge schema compatibility topic.Schemas.testCompatibility
(String topic, org.apache.pulsar.common.schema.SchemaInfo schemaInfo) Judge schema compatibility topic.void
Topics.triggerCompaction
(String topic) Trigger compaction to run for a topic.Functions.triggerFunction
(String tenant, String namespace, String function, String topic, String triggerValue, String triggerFile) Triggers the function by writing to the input topic.void
Topics.triggerOffload
(String topic, org.apache.pulsar.client.api.MessageId messageId) Trigger offloading messages in topic to longterm storage.void
Truncate a topic.void
Unload a namespace from the current serving broker.void
Deprecated.Unload a topic.void
Unload a topic.void
Namespaces.unloadNamespaceBundle
(String namespace, String bundle) Unload namespace bundle.void
Namespaces.unsubscribeNamespace
(String namespace, String subscription) Unsubscribe the given subscription on all topics on a namespace.void
Namespaces.unsubscribeNamespaceBundle
(String namespace, String bundle, String subscription) Unsubscribe the given subscription on all topics on a namespace bundle.void
Bookies.updateBookieRackInfo
(String bookieAddress, String group, BookieInfo bookieInfo) Updates the rack placement information for a specific bookie in the cluster.void
Clusters.updateCluster
(String cluster, ClusterData clusterData) Update the configuration for a cluster.void
Brokers.updateDynamicConfiguration
(String configName, String configValue) Update a dynamic configuration value into ZooKeeper.void
Clusters.updateFailureDomain
(String cluster, String domainName, FailureDomain domain) Update a domain into cluster.void
Functions.updateFunction
(FunctionConfig functionConfig, String fileName) Update the configuration for a function.void
Functions.updateFunction
(FunctionConfig functionConfig, String fileName, UpdateOptions updateOptions) Update the configuration for a function.void
Functions.updateFunctionWithUrl
(FunctionConfig functionConfig, String pkgUrl) Update the configuration for a function.void
Functions.updateFunctionWithUrl
(FunctionConfig functionConfig, String pkgUrl, UpdateOptions updateOptions) Update the configuration for a function.void
Packages.updateMetadata
(String packageName, PackageMetadata metadata) Update a package metadata information.void
Clusters.updateNamespaceIsolationPolicy
(String cluster, String policyName, NamespaceIsolationData namespaceIsolationData) Update a namespace isolation policy for a cluster.void
Topics.updatePartitionedTopic
(String topic, int numPartitions) Update number of partitions of a non-global partitioned topic.void
Topics.updatePartitionedTopic
(String topic, int numPartitions, boolean updateLocalTopicOnly) Update number of partitions of a non-global partitioned topic.void
Topics.updatePartitionedTopic
(String topic, int numPartitions, boolean updateLocalTopicOnly, boolean force) Update number of partitions of a non-global partitioned topic.void
Clusters.updatePeerClusterNames
(String cluster, LinkedHashSet<String> peerClusterNames) Update peer cluster names.void
Properties.updateProperty
(String property, TenantInfo config) Deprecated.Update the admins for a property.void
ResourceGroups.updateResourceGroup
(String name, ResourceGroup resourcegroup) Update the configuration for a ResourceGroup.void
Sinks.updateSink
(SinkConfig sinkConfig, String fileName) Update the configuration for a sink.void
Sinks.updateSink
(SinkConfig sinkConfig, String fileName, UpdateOptions updateOptions) Update the configuration for a sink.void
Sinks.updateSinkWithUrl
(SinkConfig sinkConfig, String pkgUrl) Update the configuration for a sink.void
Sinks.updateSinkWithUrl
(SinkConfig sinkConfig, String pkgUrl, UpdateOptions updateOptions) Update the configuration for a sink.void
Sources.updateSource
(SourceConfig sourceConfig, String fileName) Update the configuration for a source.void
Sources.updateSource
(SourceConfig sourceConfig, String fileName, UpdateOptions updateOptions) Update the configuration for a source.void
Sources.updateSourceWithUrl
(SourceConfig sourceConfig, String pkgUrl) Update the configuration for a source.void
Sources.updateSourceWithUrl
(SourceConfig sourceConfig, String pkgUrl, UpdateOptions updateOptions) Update the configuration for a source.void
Topics.updateSubscriptionProperties
(String topic, String subName, Map<String, String> subscriptionProperties) Update Subscription Properties on a topic subscription.void
Tenants.updateTenant
(String tenant, TenantInfo config) Update the admins for a tenant.void
Packages.upload
(PackageMetadata metadata, String packageName, String path) Upload a package to the package management service.void
Functions.uploadFunction
(String sourceFile, String path) Upload Data.