Index

A B C D E F G H I J L M N O P R S T U V W 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

aborted - Variable in class org.apache.pulsar.common.policies.data.TransactionInBufferStats
The flag of this transaction have been aborted.
ackedPartitions - Variable in class org.apache.pulsar.common.policies.data.TransactionMetadata
The ackedPartitions of this transaction.
active - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.CursorStats
 
active(boolean) - Method in interface org.apache.pulsar.common.policies.data.BrokerStatus.Builder
 
active(boolean) - Method in interface org.apache.pulsar.common.policies.data.DelayedDeliveryPolicies.Builder
 
active(boolean) - Method in class org.apache.pulsar.common.policies.data.impl.BrokerStatusImpl.BrokerStatusImplBuilder
 
active(boolean) - Method in class org.apache.pulsar.common.policies.data.impl.DelayedDeliveryPoliciesImpl.DelayedDeliveryPoliciesImplBuilder
 
add(NonPersistentTopicStats) - Method in interface org.apache.pulsar.common.policies.data.NonPersistentPartitionedTopicStats
 
add(ResourceQuota) - Method in class org.apache.pulsar.common.policies.data.ResourceQuota
Add quota.
add(TopicStats) - Method in interface org.apache.pulsar.common.policies.data.PartitionedTopicStats
 
addInstance(FunctionStatus.FunctionInstanceStatus) - Method in class org.apache.pulsar.common.policies.data.FunctionStatus
 
addInstance(SinkStatus.SinkInstanceStatus) - Method in class org.apache.pulsar.common.policies.data.SinkStatus
 
addInstance(SourceStatus.SourceInstanceStatus) - Method in class org.apache.pulsar.common.policies.data.SourceStatus
 
adminRoles(Set<String>) - Method in interface org.apache.pulsar.common.policies.data.TenantInfo.Builder
 
ALL - Enum constant in enum class org.apache.pulsar.client.admin.Mode
 
AllocatorStats - Class in org.apache.pulsar.common.stats
Allocator statistics.
AllocatorStats() - Constructor for class org.apache.pulsar.common.stats.AllocatorStats
 
AllocatorStats.PoolArenaStats - Class in org.apache.pulsar.common.stats
Pool arena statistics.
AllocatorStats.PoolChunkListStats - Class in org.apache.pulsar.common.stats
Pool chunk list statistics.
AllocatorStats.PoolChunkStats - Class in org.apache.pulsar.common.stats
Pool chunk statistics.
AllocatorStats.PoolSubpageStats - Class in org.apache.pulsar.common.stats
Pool subpage statistics.
allowAutoSubscriptionCreation(boolean) - Method in interface org.apache.pulsar.common.policies.data.AutoSubscriptionCreationOverride.Builder
 
allowAutoSubscriptionCreation(boolean) - Method in class org.apache.pulsar.common.policies.data.impl.AutoSubscriptionCreationOverrideImpl.AutoSubscriptionCreationOverrideImplBuilder
 
allowAutoTopicCreation(boolean) - Method in interface org.apache.pulsar.common.policies.data.AutoTopicCreationOverride.Builder
 
allowAutoTopicCreation(boolean) - Method in class org.apache.pulsar.common.policies.data.impl.AutoTopicCreationOverrideImpl.AutoTopicCreationOverrideImplBuilder
 
allowedClusters(Set<String>) - Method in interface org.apache.pulsar.common.policies.data.TenantInfo.Builder
 
allowTlsInsecureConnection(boolean) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder
Configure whether the Pulsar admin client accept untrusted TLS certificate from broker (default: false).
ALWAYS_COMPATIBLE - Enum constant in enum class org.apache.pulsar.common.policies.data.SchemaCompatibilityStrategy
Always compatible.
ALWAYS_INCOMPATIBLE - Enum constant in enum class org.apache.pulsar.common.policies.data.SchemaCompatibilityStrategy
Always incompatible.
AlwaysCompatible - Enum constant in enum class org.apache.pulsar.common.policies.data.SchemaAutoUpdateCompatibilityStrategy
Always Compatible - The new schema will not be checked for compatibility against old schemas.
analyzeSubscriptionBacklog(String, String, Optional<MessageId>) - Method in interface org.apache.pulsar.client.admin.Topics
Analyze subscription backlog.
analyzeSubscriptionBacklogAsync(String, String, Optional<MessageId>) - Method in interface org.apache.pulsar.client.admin.Topics
Analyze subscription backlog.
AnalyzeSubscriptionBacklogResult - Class in org.apache.pulsar.common.stats
 
AnalyzeSubscriptionBacklogResult() - Constructor for class org.apache.pulsar.common.stats.AnalyzeSubscriptionBacklogResult
 
ATLEAST_ONCE - Enum constant in enum class org.apache.pulsar.common.functions.FunctionConfig.ProcessingGuarantees
 
ATLEAST_ONCE - Enum constant in enum class org.apache.pulsar.common.functions.WindowConfig.ProcessingGuarantees
 
ATMOST_ONCE - Enum constant in enum class org.apache.pulsar.common.functions.FunctionConfig.ProcessingGuarantees
 
ATMOST_ONCE - Enum constant in enum class org.apache.pulsar.common.functions.WindowConfig.ProcessingGuarantees
 
auth_policies - Variable in class org.apache.pulsar.common.policies.data.Policies
 
AuthAction - Enum Class in org.apache.pulsar.common.policies.data
Authorization action for Pulsar policies.
authentication(String, String) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder
Set the authentication provider to use in the Pulsar client instance.
authentication(String, Map<String, String>) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder
Set the authentication provider to use in the Pulsar client instance.
authentication(Authentication) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder
Set the authentication provider to use in the Pulsar admin instance.
AuthenticationConfig - Class in org.apache.pulsar.common.functions
Configuration to aggregate various authentication params.
AuthenticationConfig() - Constructor for class org.apache.pulsar.common.functions.AuthenticationConfig
 
authenticationParameters(String) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
 
authenticationPlugin(String) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
 
AuthPolicies - Interface in org.apache.pulsar.common.policies.data
Authentication policies.
AuthPolicies.Builder - Interface in org.apache.pulsar.common.policies.data
 
autoCertRefreshTime(int, TimeUnit) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder
This sets auto cert refresh time if Pulsar admin uses tls authentication.
autoFailoverPolicy(AutoFailoverPolicyData) - Method in interface org.apache.pulsar.common.policies.data.NamespaceIsolationData.Builder
 
AutoFailoverPolicy - Class in org.apache.pulsar.common.policies
Basic definition of an auto-failover policy.
AutoFailoverPolicy() - Constructor for class org.apache.pulsar.common.policies.AutoFailoverPolicy
 
AutoFailoverPolicyData - Interface in org.apache.pulsar.common.policies.data
 
AutoFailoverPolicyData.Builder - Interface in org.apache.pulsar.common.policies.data
 
AutoFailoverPolicyFactory - Class in org.apache.pulsar.common.policies.impl
Factory to generate an instance of AutoFailoverPolicy.
AutoFailoverPolicyFactory() - Constructor for class org.apache.pulsar.common.policies.impl.AutoFailoverPolicyFactory
 
AutoFailoverPolicyType - Enum Class in org.apache.pulsar.common.policies.data
The policy type of auto failover.
autoSubscriptionCreationOverride - Variable in class org.apache.pulsar.common.policies.data.Policies
 
AutoSubscriptionCreationOverride - Interface in org.apache.pulsar.common.policies.data
Override of autoSubscriptionCreation settings on a namespace level.
AutoSubscriptionCreationOverride.Builder - Interface in org.apache.pulsar.common.policies.data
 
AutoSubscriptionCreationOverrideImpl - Class in org.apache.pulsar.common.policies.data.impl
Override of autoSubscriptionCreation settings on a topic or namespace level.
AutoSubscriptionCreationOverrideImpl() - Constructor for class org.apache.pulsar.common.policies.data.impl.AutoSubscriptionCreationOverrideImpl
 
AutoSubscriptionCreationOverrideImpl.AutoSubscriptionCreationOverrideImplBuilder - Class in org.apache.pulsar.common.policies.data.impl
 
AutoSubscriptionCreationOverrideImplBuilder() - Constructor for class org.apache.pulsar.common.policies.data.impl.AutoSubscriptionCreationOverrideImpl.AutoSubscriptionCreationOverrideImplBuilder
 
autoTopicCreationOverride - Variable in class org.apache.pulsar.common.policies.data.Policies
 
AutoTopicCreationOverride - Interface in org.apache.pulsar.common.policies.data
Override of autoTopicCreation settings on a namespace level.
AutoTopicCreationOverride.Builder - Interface in org.apache.pulsar.common.policies.data
 
AutoTopicCreationOverrideImpl - Class in org.apache.pulsar.common.policies.data.impl
Override of autoTopicCreation settings on a namespace level.
AutoTopicCreationOverrideImpl() - Constructor for class org.apache.pulsar.common.policies.data.impl.AutoTopicCreationOverrideImpl
 
AutoTopicCreationOverrideImpl.AutoTopicCreationOverrideImplBuilder - Class in org.apache.pulsar.common.policies.data.impl
 
AutoTopicCreationOverrideImplBuilder() - Constructor for class org.apache.pulsar.common.policies.data.impl.AutoTopicCreationOverrideImpl.AutoTopicCreationOverrideImplBuilder
 
AutoUpdateDisabled - Enum constant in enum class org.apache.pulsar.common.policies.data.SchemaAutoUpdateCompatibilityStrategy
Don't allow any auto updates.
averageLatency - Variable in class org.apache.pulsar.common.policies.data.FunctionStatus.FunctionInstanceStatus.FunctionInstanceStatusData
 

B

backlog_quota_map - Variable in class org.apache.pulsar.common.policies.data.Policies
 
BacklogQuota - Interface in org.apache.pulsar.common.policies.data
Unit of a backlog quota configuration for a scoped resource in a Pulsar instance.
BacklogQuota.BacklogQuotaType - Enum Class in org.apache.pulsar.common.policies.data
Identifier to a backlog quota configuration (an instance of BacklogQuota).
BacklogQuota.Builder - Interface in org.apache.pulsar.common.policies.data
 
BacklogQuota.RetentionPolicy - Enum Class in org.apache.pulsar.common.policies.data
Enumeration type determines how to retain backlog against the resource shortages.
backlogQuotaCheck() - Method in interface org.apache.pulsar.client.admin.Brokers
Manually trigger backlogQuotaCheck.
backlogQuotaCheckAsync() - Method in interface org.apache.pulsar.client.admin.Brokers
Manually trigger backlogQuotaCheck asynchronously.
BacklogQuotaImpl - Class in org.apache.pulsar.common.policies.data.impl
 
BacklogQuotaImpl(long, int, BacklogQuota.RetentionPolicy) - Constructor for class org.apache.pulsar.common.policies.data.impl.BacklogQuotaImpl
 
BacklogQuotaImpl.BacklogQuotaImplBuilder - Class in org.apache.pulsar.common.policies.data.impl
 
BacklogQuotaImplBuilder() - Constructor for class org.apache.pulsar.common.policies.data.impl.BacklogQuotaImpl.BacklogQuotaImplBuilder
 
Backward - Enum constant in enum class org.apache.pulsar.common.policies.data.SchemaAutoUpdateCompatibilityStrategy
Messages written in the previous schema can be read by the new schema.
BACKWARD - Enum constant in enum class org.apache.pulsar.common.policies.data.SchemaCompatibilityStrategy
Messages written by an old schema can be read by a new schema.
BACKWARD_TRANSITIVE - Enum constant in enum class org.apache.pulsar.common.policies.data.SchemaCompatibilityStrategy
Be similar to BACKWARD, BACKWARD_TRANSITIVE ensure all previous version schema can be read by the new schema.
BackwardTransitive - Enum constant in enum class org.apache.pulsar.common.policies.data.SchemaAutoUpdateCompatibilityStrategy
Be similar to Backward.
BATCHSOURCE_CLASSNAME_KEY - Static variable in class org.apache.pulsar.common.io.BatchSourceConfig
 
BATCHSOURCE_CONFIG_KEY - Static variable in class org.apache.pulsar.common.io.BatchSourceConfig
 
BatchSourceConfig - Class in org.apache.pulsar.common.io
Pulsar Batch Source configuration.
BatchSourceConfig() - Constructor for class org.apache.pulsar.common.io.BatchSourceConfig
 
BookieAffinityGroupData - Interface in org.apache.pulsar.common.policies.data
Description of a BookKeeper's affinity group.
BookieAffinityGroupData.Builder - Interface in org.apache.pulsar.common.policies.data
 
BookieAffinityGroupDataImpl - Class in org.apache.pulsar.common.policies.data.impl
Description of a BookKeeper's affinity group.
BookieAffinityGroupDataImpl() - Constructor for class org.apache.pulsar.common.policies.data.impl.BookieAffinityGroupDataImpl
 
BookieAffinityGroupDataImpl.BookieAffinityGroupDataImplBuilder - Class in org.apache.pulsar.common.policies.data.impl
 
BookieAffinityGroupDataImplBuilder() - Constructor for class org.apache.pulsar.common.policies.data.impl.BookieAffinityGroupDataImpl.BookieAffinityGroupDataImplBuilder
 
BookieInfo - Interface in org.apache.pulsar.common.policies.data
Bookie information.
BookieInfo.Builder - Interface in org.apache.pulsar.common.policies.data
 
BookieInfoImpl - Class in org.apache.pulsar.common.policies.data.impl
Bookie information.
BookieInfoImpl() - Constructor for class org.apache.pulsar.common.policies.data.impl.BookieInfoImpl
 
BookieInfoImpl.BookieInfoImplBuilder - Class in org.apache.pulsar.common.policies.data.impl
 
BookieInfoImplBuilder() - Constructor for class org.apache.pulsar.common.policies.data.impl.BookieInfoImpl.BookieInfoImplBuilder
 
bookies() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
 
bookies(List<RawBookieInfo>) - Method in interface org.apache.pulsar.common.policies.data.BookiesClusterInfo.Builder
 
bookies(List<RawBookieInfo>) - Method in class org.apache.pulsar.common.policies.data.impl.BookiesClusterInfoImpl.BookiesClusterInfoImplBuilder
 
Bookies - Interface in org.apache.pulsar.client.admin
Admin interface for bookies rack placement management.
BookiesClusterInfo - Interface in org.apache.pulsar.common.policies.data
Raw bookies information.
BookiesClusterInfo.Builder - Interface in org.apache.pulsar.common.policies.data
 
BookiesClusterInfoImpl - Class in org.apache.pulsar.common.policies.data.impl
Raw bookies information.
BookiesClusterInfoImpl() - Constructor for class org.apache.pulsar.common.policies.data.impl.BookiesClusterInfoImpl
 
BookiesClusterInfoImpl.BookiesClusterInfoImplBuilder - Class in org.apache.pulsar.common.policies.data.impl
 
BookiesClusterInfoImplBuilder() - Constructor for class org.apache.pulsar.common.policies.data.impl.BookiesClusterInfoImpl.BookiesClusterInfoImplBuilder
 
BookiesRackConfiguration - Class in org.apache.pulsar.common.policies.data
The rack configuration map for bookies.
BookiesRackConfiguration() - Constructor for class org.apache.pulsar.common.policies.data.BookiesRackConfiguration
 
BOOKKEEPER_FIRST - Enum constant in enum class org.apache.pulsar.common.policies.data.OffloadedReadPriority
For offloaded messages, readers will try to read from bookkeeper at first, if messages not exist at bookkeeper then read from offloaded storage.
bookkeeperAffinityGroupPrimary(String) - Method in interface org.apache.pulsar.common.policies.data.BookieAffinityGroupData.Builder
 
bookkeeperAffinityGroupPrimary(String) - Method in class org.apache.pulsar.common.policies.data.impl.BookieAffinityGroupDataImpl.BookieAffinityGroupDataImplBuilder
 
bookkeeperAffinityGroupSecondary(String) - Method in interface org.apache.pulsar.common.policies.data.BookieAffinityGroupData.Builder
 
bookkeeperAffinityGroupSecondary(String) - Method in class org.apache.pulsar.common.policies.data.impl.BookieAffinityGroupDataImpl.BookieAffinityGroupDataImplBuilder
 
boundaries(List<String>) - Method in interface org.apache.pulsar.common.policies.data.BundlesData.Builder
 
boundaries(List<String>) - Method in class org.apache.pulsar.common.policies.data.impl.BundlesDataImpl.BundlesDataImplBuilder
 
broker_assignment - Variable in class org.apache.pulsar.common.policies.data.NamespaceOwnershipStatus
 
brokerAddress(String) - Method in interface org.apache.pulsar.common.policies.data.BrokerStatus.Builder
 
brokerAddress(String) - Method in class org.apache.pulsar.common.policies.data.impl.BrokerStatusImpl.BrokerStatusImplBuilder
 
BrokerAssignment - Enum Class in org.apache.pulsar.common.policies.data
Definition of possible broker assignments.
brokerClientCertificateFilePath(String) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
 
brokerClientKeyFilePath(String) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
 
brokerClientTlsEnabled(boolean) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
 
brokerClientTlsEnabledWithKeyStore(boolean) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
 
brokerClientTlsKeyStore(String) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
 
brokerClientTlsKeyStorePassword(String) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
 
brokerClientTlsKeyStoreType(String) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
 
brokerClientTlsTrustStore(String) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
 
brokerClientTlsTrustStorePassword(String) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
 
brokerClientTlsTrustStoreType(String) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
 
brokerClientTrustCertsFilePath(String) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
 
BrokerInfo - Interface in org.apache.pulsar.common.policies.data
Broker Information.
BrokerInfo.Builder - Interface in org.apache.pulsar.common.policies.data
 
BrokerInfoImpl - Class in org.apache.pulsar.common.policies.data.impl
Broker Information.
BrokerInfoImpl() - Constructor for class org.apache.pulsar.common.policies.data.impl.BrokerInfoImpl
 
BrokerInfoImpl.BrokerInfoImplBuilder - Class in org.apache.pulsar.common.policies.data.impl
 
BrokerInfoImplBuilder() - Constructor for class org.apache.pulsar.common.policies.data.impl.BrokerInfoImpl.BrokerInfoImplBuilder
 
brokerName(String) - Method in interface org.apache.pulsar.common.policies.data.BrokerNamespaceIsolationData.Builder
 
BrokerNamespaceIsolationData - Interface in org.apache.pulsar.common.policies.data
 
BrokerNamespaceIsolationData.Builder - Interface in org.apache.pulsar.common.policies.data
 
brokers() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
 
brokers(Set<String>) - Method in interface org.apache.pulsar.common.policies.data.FailureDomain.Builder
 
Brokers - Interface in org.apache.pulsar.client.admin
Admin interface for brokers management.
brokerServiceUrl(String) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
 
brokerServiceUrlTls(String) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
 
brokerStats() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
 
BrokerStats - Interface in org.apache.pulsar.client.admin
Admin interface for brokers management.
BrokerStatus - Interface in org.apache.pulsar.common.policies.data
Information about the broker status.
BrokerStatus.Builder - Interface in org.apache.pulsar.common.policies.data
 
BrokerStatusImpl - Class in org.apache.pulsar.common.policies.data.impl
Information about the broker status.
BrokerStatusImpl() - Constructor for class org.apache.pulsar.common.policies.data.impl.BrokerStatusImpl
 
BrokerStatusImpl.BrokerStatusImplBuilder - Class in org.apache.pulsar.common.policies.data.impl
 
BrokerStatusImplBuilder() - Constructor for class org.apache.pulsar.common.policies.data.impl.BrokerStatusImpl.BrokerStatusImplBuilder
 
build() - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder
 
build() - Method in interface org.apache.pulsar.common.policies.data.AuthPolicies.Builder
 
build() - Method in interface org.apache.pulsar.common.policies.data.AutoFailoverPolicyData.Builder
 
build() - Method in interface org.apache.pulsar.common.policies.data.AutoSubscriptionCreationOverride.Builder
 
build() - Method in interface org.apache.pulsar.common.policies.data.AutoTopicCreationOverride.Builder
 
build() - Method in interface org.apache.pulsar.common.policies.data.BacklogQuota.Builder
 
build() - Method in interface org.apache.pulsar.common.policies.data.BookieAffinityGroupData.Builder
 
build() - Method in interface org.apache.pulsar.common.policies.data.BookieInfo.Builder
 
build() - Method in interface org.apache.pulsar.common.policies.data.BookiesClusterInfo.Builder
 
build() - Method in interface org.apache.pulsar.common.policies.data.BrokerInfo.Builder
 
build() - Method in interface org.apache.pulsar.common.policies.data.BrokerNamespaceIsolationData.Builder
 
build() - Method in interface org.apache.pulsar.common.policies.data.BrokerStatus.Builder
 
build() - Method in interface org.apache.pulsar.common.policies.data.BundlesData.Builder
 
build() - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
 
build() - Method in interface org.apache.pulsar.common.policies.data.DelayedDeliveryPolicies.Builder
 
build() - Method in interface org.apache.pulsar.common.policies.data.DispatchRate.Builder
 
build() - Method in interface org.apache.pulsar.common.policies.data.FailureDomain.Builder
 
build() - Method in class org.apache.pulsar.common.policies.data.impl.AutoSubscriptionCreationOverrideImpl.AutoSubscriptionCreationOverrideImplBuilder
 
build() - Method in class org.apache.pulsar.common.policies.data.impl.AutoTopicCreationOverrideImpl.AutoTopicCreationOverrideImplBuilder
 
build() - Method in class org.apache.pulsar.common.policies.data.impl.BacklogQuotaImpl.BacklogQuotaImplBuilder
 
build() - Method in class org.apache.pulsar.common.policies.data.impl.BookieAffinityGroupDataImpl.BookieAffinityGroupDataImplBuilder
 
build() - Method in class org.apache.pulsar.common.policies.data.impl.BookieInfoImpl.BookieInfoImplBuilder
 
build() - Method in class org.apache.pulsar.common.policies.data.impl.BookiesClusterInfoImpl.BookiesClusterInfoImplBuilder
 
build() - Method in class org.apache.pulsar.common.policies.data.impl.BrokerInfoImpl.BrokerInfoImplBuilder
 
build() - Method in class org.apache.pulsar.common.policies.data.impl.BrokerStatusImpl.BrokerStatusImplBuilder
 
build() - Method in class org.apache.pulsar.common.policies.data.impl.BundlesDataImpl.BundlesDataImplBuilder
 
build() - Method in class org.apache.pulsar.common.policies.data.impl.DelayedDeliveryPoliciesImpl.DelayedDeliveryPoliciesImplBuilder
 
build() - Method in class org.apache.pulsar.common.policies.data.impl.DispatchRateImpl.DispatchRateImplBuilder
 
build() - Method in interface org.apache.pulsar.common.policies.data.NamespaceIsolationData.Builder
 
build() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
 
build() - Method in interface org.apache.pulsar.common.policies.data.TenantInfo.Builder
 
builder() - Static method in interface org.apache.pulsar.client.admin.PulsarAdmin
Get a new builder instance that can used to configure and build a PulsarAdmin instance.
builder() - Static method in interface org.apache.pulsar.common.policies.data.AuthPolicies
 
builder() - Static method in interface org.apache.pulsar.common.policies.data.AutoFailoverPolicyData
 
builder() - Static method in interface org.apache.pulsar.common.policies.data.AutoSubscriptionCreationOverride
 
builder() - Static method in interface org.apache.pulsar.common.policies.data.AutoTopicCreationOverride
 
builder() - Static method in interface org.apache.pulsar.common.policies.data.BacklogQuota
 
builder() - Static method in interface org.apache.pulsar.common.policies.data.BookieAffinityGroupData
 
builder() - Static method in interface org.apache.pulsar.common.policies.data.BookieInfo
 
builder() - Static method in interface org.apache.pulsar.common.policies.data.BookiesClusterInfo
 
builder() - Static method in interface org.apache.pulsar.common.policies.data.BrokerInfo
 
builder() - Static method in interface org.apache.pulsar.common.policies.data.BrokerNamespaceIsolationData
 
builder() - Static method in interface org.apache.pulsar.common.policies.data.BrokerStatus
 
builder() - Static method in interface org.apache.pulsar.common.policies.data.BundlesData
 
builder() - Static method in interface org.apache.pulsar.common.policies.data.ClusterData
 
builder() - Static method in interface org.apache.pulsar.common.policies.data.DelayedDeliveryPolicies
 
builder() - Static method in interface org.apache.pulsar.common.policies.data.DispatchRate
 
builder() - Static method in interface org.apache.pulsar.common.policies.data.FailureDomain
 
builder() - Static method in class org.apache.pulsar.common.policies.data.impl.AutoSubscriptionCreationOverrideImpl
 
builder() - Static method in class org.apache.pulsar.common.policies.data.impl.AutoTopicCreationOverrideImpl
 
builder() - Static method in class org.apache.pulsar.common.policies.data.impl.BacklogQuotaImpl
 
builder() - Static method in class org.apache.pulsar.common.policies.data.impl.BookieAffinityGroupDataImpl
 
builder() - Static method in class org.apache.pulsar.common.policies.data.impl.BookieInfoImpl
 
builder() - Static method in class org.apache.pulsar.common.policies.data.impl.BookiesClusterInfoImpl
 
builder() - Static method in class org.apache.pulsar.common.policies.data.impl.BrokerInfoImpl
 
builder() - Static method in class org.apache.pulsar.common.policies.data.impl.BrokerStatusImpl
 
builder() - Static method in class org.apache.pulsar.common.policies.data.impl.BundlesDataImpl
 
builder() - Static method in class org.apache.pulsar.common.policies.data.impl.DelayedDeliveryPoliciesImpl
 
builder() - Static method in class org.apache.pulsar.common.policies.data.impl.DispatchRateImpl
 
builder() - Static method in interface org.apache.pulsar.common.policies.data.NamespaceIsolationData
 
builder() - Static method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
 
builder() - Static method in interface org.apache.pulsar.common.policies.data.TenantInfo
 
Bundle - Enum constant in enum class org.apache.pulsar.client.admin.Topics.QueryParam
 
bundles - Variable in class org.apache.pulsar.common.policies.data.Policies
 
BundlesData - Interface in org.apache.pulsar.common.policies.data
Holder for bundles.
BundlesData.Builder - Interface in org.apache.pulsar.common.policies.data
 
BundlesDataImpl - Class in org.apache.pulsar.common.policies.data.impl
Holder for bundles.
BundlesDataImpl() - Constructor for class org.apache.pulsar.common.policies.data.impl.BundlesDataImpl
 
BundlesDataImpl.BundlesDataImplBuilder - Class in org.apache.pulsar.common.policies.data.impl
 
BundlesDataImplBuilder() - Constructor for class org.apache.pulsar.common.policies.data.impl.BundlesDataImpl.BundlesDataImplBuilder
 
BYTES_IN_GIGABYTE - Static variable in class org.apache.pulsar.common.policies.data.impl.BacklogQuotaImpl
 

C

cacheSize - Variable in class org.apache.pulsar.policies.data.loadbalancer.NamespaceBundleStats
 
calculateOverall() - Method in interface org.apache.pulsar.common.policies.data.FunctionStats
 
checkArgument(boolean, Object) - Static method in class org.apache.pulsar.common.policies.data.impl.BookieInfoImpl.BookieInfoImplBuilder
 
chunkLists - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolArenaStats
 
chunks - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolChunkListStats
 
chunkSize - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolChunkStats
 
clearNamespaceBacklog(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Clear backlog for all topics on a namespace.
clearNamespaceBacklogAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Clear backlog for all topics on a namespace asynchronously.
clearNamespaceBacklogForSubscription(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Clear backlog for a given subscription on all topics on a namespace.
clearNamespaceBacklogForSubscriptionAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Clear backlog for a given subscription on all topics on a namespace asynchronously.
clearNamespaceBundleBacklog(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Clear backlog for all topics on a namespace bundle.
clearNamespaceBundleBacklogAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Clear backlog for all topics on a namespace bundle asynchronously.
clearNamespaceBundleBacklogForSubscription(String, String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Clear backlog for a given subscription on all topics on a namespace bundle.
clearNamespaceBundleBacklogForSubscriptionAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Clear backlog for a given subscription on all topics on a namespace bundle asynchronously.
clearOffloadDeleteLag(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Clear the offload deletion lag for a namespace.
clearOffloadDeleteLagAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Clear the offload deletion lag for a namespace asynchronously.
clearProperties(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Clear all properties of a namespace.
clearPropertiesAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Clear all properties of a namespace asynchronously.
clone() - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder
Create a copy of the current client builder.
clone() - Method in exception org.apache.pulsar.client.admin.PulsarAdminException
This method is meant to be overriden by all subclasses.
clone() - Method in exception org.apache.pulsar.client.admin.PulsarAdminException.ConflictException
 
clone() - Method in exception org.apache.pulsar.client.admin.PulsarAdminException.ConnectException
 
clone() - Method in exception org.apache.pulsar.client.admin.PulsarAdminException.GettingAuthenticationDataException
 
clone() - Method in exception org.apache.pulsar.client.admin.PulsarAdminException.HttpErrorException
 
clone() - Method in exception org.apache.pulsar.client.admin.PulsarAdminException.NotAllowedException
 
clone() - Method in exception org.apache.pulsar.client.admin.PulsarAdminException.NotAuthorizedException
 
clone() - Method in exception org.apache.pulsar.client.admin.PulsarAdminException.NotFoundException
 
clone() - Method in exception org.apache.pulsar.client.admin.PulsarAdminException.PreconditionFailedException
 
clone() - Method in exception org.apache.pulsar.client.admin.PulsarAdminException.ServerSideErrorException
 
clone() - Method in exception org.apache.pulsar.client.admin.PulsarAdminException.TimeoutException
 
clone() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
 
close() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
Close the PulsarAdminClient and release all the resources.
ClusterData - Interface in org.apache.pulsar.common.policies.data
 
ClusterData.Builder - Interface in org.apache.pulsar.common.policies.data
 
ClusterData.ClusterUrl - Class in org.apache.pulsar.common.policies.data
 
clusterDispatchRate - Variable in class org.apache.pulsar.common.policies.data.Policies
Deprecated.
clusters() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
 
Clusters - Interface in org.apache.pulsar.client.admin
Admin interface for clusters management.
clusterSubscribeRate - Variable in class org.apache.pulsar.common.policies.data.Policies
 
ClusterUrl() - Constructor for class org.apache.pulsar.common.policies.data.ClusterData.ClusterUrl
 
compactedLedger - Variable in class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats
 
compaction_threshold - Variable in class org.apache.pulsar.common.policies.data.Policies
 
CompactionStats - Interface in org.apache.pulsar.common.policies.data
Statistics about compaction.
compactionStatus(String) - Method in interface org.apache.pulsar.client.admin.Topics
Check the status of an ongoing compaction for a topic.
compactionStatusAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
Check the status of an ongoing compaction for a topic asynchronously.
compareByBandwidthIn(NamespaceBundleStats) - Method in class org.apache.pulsar.policies.data.loadbalancer.NamespaceBundleStats
 
compareByBandwidthOut(NamespaceBundleStats) - Method in class org.apache.pulsar.policies.data.loadbalancer.NamespaceBundleStats
 
compareByCacheSize(NamespaceBundleStats) - Method in class org.apache.pulsar.policies.data.loadbalancer.NamespaceBundleStats
 
compareByMsgRate(NamespaceBundleStats) - Method in class org.apache.pulsar.policies.data.loadbalancer.NamespaceBundleStats
 
compareByTopicConnections(NamespaceBundleStats) - Method in class org.apache.pulsar.policies.data.loadbalancer.NamespaceBundleStats
 
compareTo(BrokerStatus) - Method in class org.apache.pulsar.common.policies.data.impl.BrokerStatusImpl
 
compareTo(NamespaceBundleStats) - Method in class org.apache.pulsar.policies.data.loadbalancer.NamespaceBundleStats
 
compareTo(ResourceUsage) - Method in class org.apache.pulsar.policies.data.loadbalancer.ResourceUsage
this may be wrong since we are comparing available and not the usage.
ConflictException(Throwable, String, int) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.ConflictException
 
ConnectException(String, Throwable) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.ConnectException
 
ConnectException(Throwable) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.ConnectException
 
connectionTimeout(int, TimeUnit) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder
This sets the connection time out for the pulsar admin client.
ConnectorDefinition - Class in org.apache.pulsar.common.io
Basic information about a Pulsar connector.
ConnectorDefinition() - Constructor for class org.apache.pulsar.common.io.ConnectorDefinition
 
consume - Enum constant in enum class org.apache.pulsar.common.policies.data.AuthAction
Permission to consume messages.
consumer_backlog_eviction - Enum constant in enum class org.apache.pulsar.common.policies.data.BacklogQuota.RetentionPolicy
Policy which evicts the oldest message from the slowest consumer's backlog.
ConsumerConfig - Class in org.apache.pulsar.common.functions
Configuration of a consumer.
ConsumerConfig(String) - Constructor for class org.apache.pulsar.common.functions.ConsumerConfig
 
consumerCount - Variable in class org.apache.pulsar.policies.data.loadbalancer.NamespaceBundleStats
 
ConsumerStats - Interface in org.apache.pulsar.common.policies.data
Consumer statistics.
create(Map<String, String>) - Static method in class org.apache.pulsar.common.stats.Metrics
Creates a metrics object with the dimensions map immutable.
create(AutoFailoverPolicyData) - Static method in class org.apache.pulsar.common.policies.impl.AutoFailoverPolicyFactory
 
createCluster(String, ClusterData) - Method in interface org.apache.pulsar.client.admin.Clusters
Create a new cluster.
createClusterAsync(String, ClusterData) - Method in interface org.apache.pulsar.client.admin.Clusters
Create a new cluster asynchronously.
createFailureDomain(String, String, FailureDomain) - Method in interface org.apache.pulsar.client.admin.Clusters
Create a domain into cluster.
createFailureDomainAsync(String, String, FailureDomain) - Method in interface org.apache.pulsar.client.admin.Clusters
Create a domain into cluster asynchronously.
createFunction(FunctionConfig, String) - Method in interface org.apache.pulsar.client.admin.Functions
Create a new function.
createFunctionAsync(FunctionConfig, String) - Method in interface org.apache.pulsar.client.admin.Functions
Create a new function asynchronously.
createFunctionWithUrl(FunctionConfig, String) - Method in interface org.apache.pulsar.client.admin.Functions
Create a new function with package url.
createFunctionWithUrlAsync(FunctionConfig, String) - Method in interface org.apache.pulsar.client.admin.Functions
Create a new function with package url asynchronously.
createMissedPartitions(String) - Method in interface org.apache.pulsar.client.admin.Topics
Create missed partitions for partitioned topic.
createMissedPartitionsAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
Create missed partitions for partitioned topic asynchronously.
createNamespace(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Create a new namespace.
createNamespace(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces
Create a new namespace.
createNamespace(String, Set<String>) - Method in interface org.apache.pulsar.client.admin.Namespaces
Create a new namespace.
createNamespace(String, BundlesData) - Method in interface org.apache.pulsar.client.admin.Namespaces
Create a new namespace.
createNamespace(String, Policies) - Method in interface org.apache.pulsar.client.admin.Namespaces
Create a new namespace.
createNamespaceAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Create a new namespace asynchronously.
createNamespaceAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces
Create a new namespace.
createNamespaceAsync(String, Set<String>) - Method in interface org.apache.pulsar.client.admin.Namespaces
Create a new namespace asynchronously.
createNamespaceAsync(String, BundlesData) - Method in interface org.apache.pulsar.client.admin.Namespaces
Create a new namespace asynchronously.
createNamespaceAsync(String, Policies) - Method in interface org.apache.pulsar.client.admin.Namespaces
Create a new namespace asynchronously.
createNamespaceIsolationPolicy(String, String, NamespaceIsolationData) - Method in interface org.apache.pulsar.client.admin.Clusters
Create a namespace isolation policy for a cluster.
createNamespaceIsolationPolicyAsync(String, String, NamespaceIsolationData) - Method in interface org.apache.pulsar.client.admin.Clusters
Create a namespace isolation policy for a cluster asynchronously.
createNonPartitionedTopic(String) - Method in interface org.apache.pulsar.client.admin.Topics
Create a non-partitioned topic.
createNonPartitionedTopic(String, Map<String, String>) - Method in interface org.apache.pulsar.client.admin.Topics
Create a non-partitioned topic.
createNonPartitionedTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
Create a non-partitioned topic asynchronously.
createNonPartitionedTopicAsync(String, Map<String, String>) - Method in interface org.apache.pulsar.client.admin.Topics
Create a non-partitioned topic asynchronously.
createPartitionedTopic(String, int) - Method in interface org.apache.pulsar.client.admin.NonPersistentTopics
Deprecated.
Create a partitioned topic.
createPartitionedTopic(String, int) - Method in interface org.apache.pulsar.client.admin.Topics
Create a partitioned topic.
createPartitionedTopic(String, int, Map<String, String>) - Method in interface org.apache.pulsar.client.admin.Topics
Create a partitioned topic.
createPartitionedTopicAsync(String, int) - Method in interface org.apache.pulsar.client.admin.NonPersistentTopics
Deprecated.
Create a partitioned topic asynchronously.
createPartitionedTopicAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Topics
Create a partitioned topic asynchronously.
createPartitionedTopicAsync(String, int, Map<String, String>) - Method in interface org.apache.pulsar.client.admin.Topics
Create a partitioned topic asynchronously.
createProperty(String, TenantInfo) - Method in interface org.apache.pulsar.client.admin.Properties
Deprecated.
Create a new property.
createResourceGroup(String, ResourceGroup) - Method in interface org.apache.pulsar.client.admin.ResourceGroups
Create a new resourcegroup.
createResourceGroupAsync(String, ResourceGroup) - Method in interface org.apache.pulsar.client.admin.ResourceGroups
Create a new resourcegroup.
createSchema(String, PostSchemaPayload) - Method in interface org.apache.pulsar.client.admin.Schemas
Create a schema for a given topic.
createSchema(String, SchemaInfo) - Method in interface org.apache.pulsar.client.admin.Schemas
Create a schema for a given topic with the provided schema info.
createSchemaAsync(String, PostSchemaPayload) - Method in interface org.apache.pulsar.client.admin.Schemas
Create a schema for a given topic asynchronously.
createSchemaAsync(String, SchemaInfo) - Method in interface org.apache.pulsar.client.admin.Schemas
Create a schema for a given topic with the provided schema info asynchronously.
createShadowTopic(String, String) - Method in interface org.apache.pulsar.client.admin.Topics
Create a new shadow topic, see #Topics.createShadowTopic(String, String, Map) for details.
createShadowTopic(String, String, Map<String, String>) - Method in interface org.apache.pulsar.client.admin.Topics
Create a new shadow topic as the shadow of the source topic.
createShadowTopicAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Topics
Create a new shadow topic, see #Topics.createShadowTopic(String, String, Map) for details.
createShadowTopicAsync(String, String, Map<String, String>) - Method in interface org.apache.pulsar.client.admin.Topics
Create a new shadow topic, see #Topics.createShadowTopic(String, String, Map) for details.
createSink(SinkConfig, String) - Method in interface org.apache.pulsar.client.admin.Sinks
Create a new sink.
createSinkAsync(SinkConfig, String) - Method in interface org.apache.pulsar.client.admin.Sinks
Create a new sink asynchronously.
createSinkWithUrl(SinkConfig, String) - Method in interface org.apache.pulsar.client.admin.Sinks
Create a new sink with package url.
createSinkWithUrlAsync(SinkConfig, String) - Method in interface org.apache.pulsar.client.admin.Sinks
Create a new sink with package url asynchronously.
createSource(SourceConfig, String) - Method in interface org.apache.pulsar.client.admin.Sources
Create a new source.
createSourceAsync(SourceConfig, String) - Method in interface org.apache.pulsar.client.admin.Sources
Create a new source asynchronously.
createSourceWithUrl(SourceConfig, String) - Method in interface org.apache.pulsar.client.admin.Sources
Create a new source with package url.
createSourceWithUrlAsync(SourceConfig, String) - Method in interface org.apache.pulsar.client.admin.Sources
Create a new source with package url asynchronously.
createSubscription(String, String, MessageId) - Method in interface org.apache.pulsar.client.admin.Topics
Create a new subscription on a topic.
createSubscription(String, String, MessageId, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
Create a new subscription on a topic.
createSubscription(String, String, MessageId, boolean, Map<String, String>) - Method in interface org.apache.pulsar.client.admin.Topics
Create a new subscription on a topic.
createSubscriptionAsync(String, String, MessageId) - Method in interface org.apache.pulsar.client.admin.Topics
Create a new subscription on a topic.
createSubscriptionAsync(String, String, MessageId, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
Create a new subscription on a topic.
createSubscriptionAsync(String, String, MessageId, boolean, Map<String, String>) - Method in interface org.apache.pulsar.client.admin.Topics
Create a new subscription on a topic.
createTenant(String, TenantInfo) - Method in interface org.apache.pulsar.client.admin.Tenants
Create a new tenant.
createTenantAsync(String, TenantInfo) - Method in interface org.apache.pulsar.client.admin.Tenants
Create a new tenant asynchronously.
CryptoConfig - Class in org.apache.pulsar.common.functions
Configuration of the producer inside the function.
CryptoConfig() - Constructor for class org.apache.pulsar.common.functions.CryptoConfig
 
cumulativeAckPosition - Variable in class org.apache.pulsar.common.policies.data.TransactionInPendingAckStats
The position of this transaction cumulative ack.
currentLedgerEntries - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats
The count of messages written to the ledger that is currently open for writing.
currentLedgerSize - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats
The size of messages written to the ledger that is currently open for writing (in bytes).
currentSegmentCapacity - Variable in class org.apache.pulsar.common.policies.data.SegmentsStats
 
cursorLedger - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.CursorStats
 
cursorLedgerLastEntry - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.CursorStats
 
cursors - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats
The list of all cursors on this topic.
CursorStats() - Constructor for class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.CursorStats
 

D

deduplicationEnabled - Variable in class org.apache.pulsar.common.policies.data.Policies
 
deduplicationSnapshotIntervalSeconds - Variable in class org.apache.pulsar.common.policies.data.Policies
 
DefaultImplementation - Class in org.apache.pulsar.client.admin.utils
Helper class for class instantiations and it also contains methods to work with schemas.
DefaultImplementation() - Constructor for class org.apache.pulsar.client.admin.utils.DefaultImplementation
 
defaultNumPartitions(Integer) - Method in interface org.apache.pulsar.common.policies.data.AutoTopicCreationOverride.Builder
 
defaultNumPartitions(Integer) - Method in class org.apache.pulsar.common.policies.data.impl.AutoTopicCreationOverrideImpl.AutoTopicCreationOverrideImplBuilder
 
delayed_delivery_policies - Variable in class org.apache.pulsar.common.policies.data.Policies
 
DelayedDeliveryPolicies - Interface in org.apache.pulsar.common.policies.data
Definition of the delayed delivery policy.
DelayedDeliveryPolicies.Builder - Interface in org.apache.pulsar.common.policies.data
 
DelayedDeliveryPoliciesImpl - Class in org.apache.pulsar.common.policies.data.impl
Definition of the delayed delivery policy.
DelayedDeliveryPoliciesImpl() - Constructor for class org.apache.pulsar.common.policies.data.impl.DelayedDeliveryPoliciesImpl
 
DelayedDeliveryPoliciesImpl.DelayedDeliveryPoliciesImplBuilder - Class in org.apache.pulsar.common.policies.data.impl
 
DelayedDeliveryPoliciesImplBuilder() - Constructor for class org.apache.pulsar.common.policies.data.impl.DelayedDeliveryPoliciesImpl.DelayedDeliveryPoliciesImplBuilder
 
delete(String) - Method in interface org.apache.pulsar.client.admin.Packages
Delete the specified package.
delete(String) - Method in interface org.apache.pulsar.client.admin.Topics
Delete a topic.
delete(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
 
delete(String, boolean, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
Deprecated.
Use Topics.delete(String, boolean) instead because parameter `deleteSchema` is always true
delete_when_no_subscriptions - Enum constant in enum class org.apache.pulsar.common.policies.data.InactiveTopicDeleteMode
The topic can be deleted when no subscriptions and no active producers.
delete_when_subscriptions_caught_up - Enum constant in enum class org.apache.pulsar.common.policies.data.InactiveTopicDeleteMode
The topic can be deleted when all subscriptions catchup and no active producers.
deleteAsync(String) - Method in interface org.apache.pulsar.client.admin.Packages
Delete the specified package asynchronously.
deleteAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
Delete a topic asynchronously.
deleteAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
 
deleteAsync(String, boolean, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
Deprecated.
Use Topics.deleteAsync(String, boolean) instead because parameter `deleteSchema` is always true
deleteBookieAffinityGroup(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Delete bookie affinity group configured for a namespace.
deleteBookieAffinityGroupAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Delete bookie affinity group configured for a namespace asynchronously.
deleteBookieRackInfo(String) - Method in interface org.apache.pulsar.client.admin.Bookies
Remove rack placement information for a specific bookie in the cluster.
deleteBookieRackInfoAsync(String) - Method in interface org.apache.pulsar.client.admin.Bookies
Remove rack placement information for a specific bookie in the cluster asynchronously.
deleteCluster(String) - Method in interface org.apache.pulsar.client.admin.Clusters
Delete an existing cluster.
deleteClusterAsync(String) - Method in interface org.apache.pulsar.client.admin.Clusters
Delete an existing cluster asynchronously.
deleted - Variable in class org.apache.pulsar.common.partition.PartitionedTopicMetadata
 
deleted - Variable in class org.apache.pulsar.common.policies.data.Policies
 
deleteDynamicConfiguration(String) - Method in interface org.apache.pulsar.client.admin.Brokers
It deletes dynamic configuration value into ZooKeeper.
deleteDynamicConfigurationAsync(String) - Method in interface org.apache.pulsar.client.admin.Brokers
It deletes dynamic configuration value into ZooKeeper asynchronously.
deleteFailureDomain(String, String) - Method in interface org.apache.pulsar.client.admin.Clusters
Delete a domain in cluster.
deleteFailureDomainAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Clusters
Delete a domain in cluster asynchronously.
deleteFunction(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions
Delete an existing function.
deleteFunctionAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions
Delete an existing function asynchronously.
deleteNamespace(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Delete an existing namespace.
deleteNamespace(String, boolean) - Method in interface org.apache.pulsar.client.admin.Namespaces
Delete an existing namespace.
deleteNamespaceAntiAffinityGroup(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Delete anti-affinity group name for a namespace.
deleteNamespaceAntiAffinityGroupAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Delete anti-affinity group name for a namespace.
deleteNamespaceAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Delete an existing namespace asynchronously.
deleteNamespaceAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Namespaces
Delete an existing namespace asynchronously.
deleteNamespaceBundle(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Delete an existing bundle in a namespace.
deleteNamespaceBundle(String, String, boolean) - Method in interface org.apache.pulsar.client.admin.Namespaces
Delete an existing bundle in a namespace.
deleteNamespaceBundleAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Delete an existing bundle in a namespace asynchronously.
deleteNamespaceBundleAsync(String, String, boolean) - Method in interface org.apache.pulsar.client.admin.Namespaces
Delete an existing bundle in a namespace asynchronously.
deleteNamespaceIsolationPolicy(String, String) - Method in interface org.apache.pulsar.client.admin.Clusters
Delete a namespace isolation policy for a cluster.
deleteNamespaceIsolationPolicyAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Clusters
Delete a namespace isolation policy for a cluster asynchronously.
deletePartitionedTopic(String) - Method in interface org.apache.pulsar.client.admin.Topics
Delete a partitioned topic.
deletePartitionedTopic(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
 
deletePartitionedTopic(String, boolean, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
Deprecated.
Use Topics.deletePartitionedTopic(String, boolean) instead because parameter `deleteSchema` is always true
deletePartitionedTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
Delete a partitioned topic asynchronously.
deletePartitionedTopicAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
 
deletePartitionedTopicAsync(String, boolean, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
Deprecated.
Use Topics.deletePartitionedTopicAsync(String, boolean) instead because parameter `deleteSchema` is always true
deleteProperty(String) - Method in interface org.apache.pulsar.client.admin.Properties
Deprecated.
Delete an existing property.
deleteResourceGroup(String) - Method in interface org.apache.pulsar.client.admin.ResourceGroups
Delete an existing resourcegroup.
deleteResourceGroupAsync(String) - Method in interface org.apache.pulsar.client.admin.ResourceGroups
Delete an existing resourcegroup.
deleteSchema(String) - Method in interface org.apache.pulsar.client.admin.Schemas
Delete the schema associated with a given topic.
deleteSchema(String, boolean) - Method in interface org.apache.pulsar.client.admin.Schemas
Delete the schema associated with a given topic.
deleteSchemaAsync(String) - Method in interface org.apache.pulsar.client.admin.Schemas
Delete the schema associated with a given topic asynchronously.
deleteSchemaAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Schemas
Delete the schema associated with a given topic asynchronously.
deleteSink(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sinks
Delete an existing sink.
deleteSinkAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sinks
Delete an existing sink asynchronously.
deleteSource(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sources
Delete an existing source.
deleteSourceAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sources
Delete an existing source asynchronously.
deleteSubscription(String, String) - Method in interface org.apache.pulsar.client.admin.Topics
Delete a subscription.
deleteSubscription(String, String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
Delete a subscription.
deleteSubscriptionAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Topics
Delete a subscription asynchronously.
deleteSubscriptionAsync(String, String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
Delete a subscription asynchronously.
deleteTenant(String) - Method in interface org.apache.pulsar.client.admin.Tenants
Delete an existing tenant.
deleteTenant(String, boolean) - Method in interface org.apache.pulsar.client.admin.Tenants
Delete an existing tenant.
deleteTenantAsync(String) - Method in interface org.apache.pulsar.client.admin.Tenants
Delete an existing tenant asynchronously.
deleteTenantAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Tenants
Delete an existing tenant asynchronously.
destination_storage - Enum constant in enum class org.apache.pulsar.common.policies.data.BacklogQuota.BacklogQuotaType
 
directArenas - Variable in class org.apache.pulsar.common.stats.AllocatorStats
 
disableDeduplication(String) - Method in interface org.apache.pulsar.client.admin.Topics
disableDeduplicationAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
DispatchRate - Interface in org.apache.pulsar.common.policies.data
Dispatch rate.
DispatchRate.Builder - Interface in org.apache.pulsar.common.policies.data
 
DispatchRateImpl - Class in org.apache.pulsar.common.policies.data.impl
Dispatch rate.
DispatchRateImpl() - Constructor for class org.apache.pulsar.common.policies.data.impl.DispatchRateImpl
 
DispatchRateImpl.DispatchRateImplBuilder - Class in org.apache.pulsar.common.policies.data.impl
 
DispatchRateImplBuilder() - Constructor for class org.apache.pulsar.common.policies.data.impl.DispatchRateImpl.DispatchRateImplBuilder
 
dispatchThrottlingRateInByte(long) - Method in interface org.apache.pulsar.common.policies.data.DispatchRate.Builder
 
dispatchThrottlingRateInByte(long) - Method in class org.apache.pulsar.common.policies.data.impl.DispatchRateImpl.DispatchRateImplBuilder
 
dispatchThrottlingRateInMsg(int) - Method in interface org.apache.pulsar.common.policies.data.DispatchRate.Builder
 
dispatchThrottlingRateInMsg(int) - Method in class org.apache.pulsar.common.policies.data.impl.DispatchRateImpl.DispatchRateImplBuilder
 
download(String, String) - Method in interface org.apache.pulsar.client.admin.Packages
Download a package from the package management service.
downloadAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Packages
Download a package from the package management service asynchronously.
downloadFunction(String, String) - Method in interface org.apache.pulsar.client.admin.Functions
Download Function Code.
downloadFunction(String, String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions
Download Function Code.
downloadFunction(String, String, String, String, boolean) - Method in interface org.apache.pulsar.client.admin.Functions
Download Function Code.
downloadFunctionAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Functions
Download Function Code.
downloadFunctionAsync(String, String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions
Download Function Code asynchronously.
downloadFunctionAsync(String, String, String, String, boolean) - Method in interface org.apache.pulsar.client.admin.Functions
Download Function Code asynchronously.

E

EFFECTIVELY_ONCE - Enum constant in enum class org.apache.pulsar.common.functions.FunctionConfig.ProcessingGuarantees
 
elementSize - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolSubpageStats
 
EMPTY - Static variable in class org.apache.pulsar.client.admin.ListNamespaceTopicsOptions
 
EMPTY - Static variable in class org.apache.pulsar.client.admin.ListTopicsOptions
 
enableDeduplication(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
enableDeduplicationAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
enableTlsHostnameVerification(boolean) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder
It allows to validate hostname verification when client connects to broker over TLS.
encryption_required - Variable in class org.apache.pulsar.common.policies.data.Policies
 
entries - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.LedgerInfo
 
entriesAddedCounter - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats
Messages published since this broker loaded this managedLedger.
entryFilters - Variable in class org.apache.pulsar.common.policies.data.Policies
 
EntryFilters - Class in org.apache.pulsar.common.policies.data
 
EntryFilters() - Constructor for class org.apache.pulsar.common.policies.data.EntryFilters
 
equals(Object) - Method in class org.apache.pulsar.common.conf.InternalConfigurationData
 
equals(Object) - Method in class org.apache.pulsar.common.policies.data.PersistencePolicies
 
equals(Object) - Method in class org.apache.pulsar.common.policies.data.Policies
 
equals(Object) - Method in class org.apache.pulsar.common.policies.data.PublishRate
 
equals(Object) - Method in class org.apache.pulsar.common.policies.data.RetentionPolicies
 
equals(Object) - Method in class org.apache.pulsar.common.policies.data.SubscribeRate
 
equals(Object) - Method in class org.apache.pulsar.common.stats.Metrics
 
equalsName(String) - Method in enum class org.apache.pulsar.common.policies.data.OffloadedReadPriority
 
error - Variable in class org.apache.pulsar.common.policies.data.FunctionStatus.FunctionInstanceStatus.FunctionInstanceStatusData
 
error - Variable in class org.apache.pulsar.common.policies.data.SinkStatus.SinkInstanceStatus.SinkInstanceStatusData
 
error - Variable in class org.apache.pulsar.common.policies.data.SourceStatus.SourceInstanceStatus.SourceInstanceStatusData
 
ERROR - Enum constant in enum class org.apache.pulsar.client.admin.LongRunningProcessStatus.Status
 
ErrorData - Class in org.apache.pulsar.common.policies.data
Class holding data in case of error responses.
ErrorData() - Constructor for class org.apache.pulsar.common.policies.data.ErrorData
 
ErrorData(String) - Constructor for class org.apache.pulsar.common.policies.data.ErrorData
 
examineMessage(String, String, long) - Method in interface org.apache.pulsar.client.admin.Topics
Examine a specific message on a topic by position relative to the earliest or the latest message.
examineMessageAsync(String, String, long) - Method in interface org.apache.pulsar.client.admin.Topics
Examine a specific message on a topic by position relative to the earliest or the latest message.
ExceptionInformation - Class in org.apache.pulsar.common.policies.data
Exception information.
ExceptionInformation() - Constructor for class org.apache.pulsar.common.policies.data.ExceptionInformation
 
expireMessages(String, String, long) - Method in interface org.apache.pulsar.client.admin.Topics
Expire all messages older than given N (expireTimeInSeconds) seconds for a given subscription.
expireMessages(String, String, MessageId, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
Expire all messages older than given N (expireTimeInSeconds) seconds for a given subscription.
expireMessagesAsync(String, String, long) - Method in interface org.apache.pulsar.client.admin.Topics
Expire all messages older than given N (expireTimeInSeconds) seconds for a given subscription asynchronously.
expireMessagesAsync(String, String, MessageId, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
Expire all messages older than given N (expireTimeInSeconds) seconds for a given subscription asynchronously.
expireMessagesForAllSubscriptions(String, long) - Method in interface org.apache.pulsar.client.admin.Topics
Expire all messages older than given N seconds for all subscriptions of the persistent-topic.
expireMessagesForAllSubscriptionsAsync(String, long) - Method in interface org.apache.pulsar.client.admin.Topics
Expire all messages older than given N seconds for all subscriptions of the persistent-topic asynchronously.

F

fail(String) - Static method in class org.apache.pulsar.common.policies.data.ValidateResult
 
FailureDomain - Interface in org.apache.pulsar.common.policies.data
 
FailureDomain.Builder - Interface in org.apache.pulsar.common.policies.data
 
fileSystemProfilePath(String) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
 
fileSystemURI(String) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
 
FIRST_BOUNDARY - Static variable in class org.apache.pulsar.common.policies.data.Policies
 
forError(String) - Static method in class org.apache.pulsar.client.admin.LongRunningProcessStatus
 
forError(String) - Static method in interface org.apache.pulsar.client.admin.OffloadProcessStatus
 
forStatus(LongRunningProcessStatus.Status) - Static method in class org.apache.pulsar.client.admin.LongRunningProcessStatus
 
forStatus(LongRunningProcessStatus.Status) - Static method in interface org.apache.pulsar.client.admin.OffloadProcessStatus
 
forSuccess(MessageId) - Static method in interface org.apache.pulsar.client.admin.OffloadProcessStatus
 
Forward - Enum constant in enum class org.apache.pulsar.common.policies.data.SchemaAutoUpdateCompatibilityStrategy
Messages written in the new schema can be read by the previous schema.
FORWARD - Enum constant in enum class org.apache.pulsar.common.policies.data.SchemaCompatibilityStrategy
Messages written by a new schema can be read by an old schema.
FORWARD_TRANSITIVE - Enum constant in enum class org.apache.pulsar.common.policies.data.SchemaCompatibilityStrategy
Be similar to FORWARD, FORWARD_TRANSITIVE ensure new schema can be ready by all previous version schema.
ForwardTransitive - Enum constant in enum class org.apache.pulsar.common.policies.data.SchemaAutoUpdateCompatibilityStrategy
Be similar to Forward, ForwardTransitive ensure new schema can be ready by all previous version schema.
freeBytes - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolChunkStats
 
fromAutoUpdatePolicy(SchemaAutoUpdateCompatibilityStrategy) - Static method in enum class org.apache.pulsar.common.policies.data.SchemaCompatibilityStrategy
 
fromString(String) - Static method in enum class org.apache.pulsar.common.policies.data.AutoFailoverPolicyType
 
fromString(String) - Static method in enum class org.apache.pulsar.common.policies.data.OffloadedReadPriority
 
Full - Enum constant in enum class org.apache.pulsar.common.policies.data.SchemaAutoUpdateCompatibilityStrategy
Backward and Forward.
FULL - Enum constant in enum class org.apache.pulsar.common.policies.data.SchemaCompatibilityStrategy
Equivalent to both FORWARD and BACKWARD.
FULL_TRANSITIVE - Enum constant in enum class org.apache.pulsar.common.policies.data.SchemaCompatibilityStrategy
Equivalent to both FORWARD_TRANSITIVE and BACKWARD_TRANSITIVE.
FullTransitive - Enum constant in enum class org.apache.pulsar.common.policies.data.SchemaAutoUpdateCompatibilityStrategy
BackwardTransitive and ForwardTransitive.
FUNCTION - Enum constant in enum class org.apache.pulsar.packages.management.core.common.PackageType
 
FunctionConfig - Class in org.apache.pulsar.common.functions
Configuration of Pulsar Function.
FunctionConfig() - Constructor for class org.apache.pulsar.common.functions.FunctionConfig
 
FunctionConfig.ProcessingGuarantees - Enum Class in org.apache.pulsar.common.functions
Definition of possible processing guarantees.
FunctionConfig.Runtime - Enum Class in org.apache.pulsar.common.functions
Definition of possible runtime environments.
FunctionDefinition - Class in org.apache.pulsar.common.functions
Basic information about a Pulsar function.
FunctionDefinition() - Constructor for class org.apache.pulsar.common.functions.FunctionDefinition
 
FunctionInstanceStats - Interface in org.apache.pulsar.common.policies.data
 
FunctionInstanceStatsData - Interface in org.apache.pulsar.common.policies.data
 
FunctionInstanceStatsDataBase - Interface in org.apache.pulsar.common.policies.data
 
FunctionInstanceStatus() - Constructor for class org.apache.pulsar.common.policies.data.FunctionStatus.FunctionInstanceStatus
 
FunctionInstanceStatusData() - Constructor for class org.apache.pulsar.common.policies.data.FunctionStatus.FunctionInstanceStatus.FunctionInstanceStatusData
 
functions - Enum constant in enum class org.apache.pulsar.common.policies.data.AuthAction
Permissions for functions ops.
functions() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
 
Functions - Interface in org.apache.pulsar.client.admin
Admin interface for function management.
FunctionState - Class in org.apache.pulsar.common.functions
Function state.
FunctionState() - Constructor for class org.apache.pulsar.common.functions.FunctionState
 
FunctionStats - Interface in org.apache.pulsar.common.policies.data
 
FunctionStatus - Class in org.apache.pulsar.common.policies.data
Data lass containing status of Pulsar Function.
FunctionStatus() - Constructor for class org.apache.pulsar.common.policies.data.FunctionStatus
 
FunctionStatus.FunctionInstanceStatus - Class in org.apache.pulsar.common.policies.data
Function instance status.
FunctionStatus.FunctionInstanceStatus.FunctionInstanceStatusData - Class in org.apache.pulsar.common.policies.data
Function instance status data.

G

gcsManagedLedgerOffloadBucket(String) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
 
gcsManagedLedgerOffloadMaxBlockSizeInBytes(Integer) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
 
gcsManagedLedgerOffloadReadBufferSizeInBytes(Integer) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
 
gcsManagedLedgerOffloadRegion(String) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
 
gcsManagedLedgerOffloadServiceAccountKeyFile(String) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
 
getAccessMode() - Method in interface org.apache.pulsar.common.policies.data.PublisherStats
 
getActiveBrokers() - Method in interface org.apache.pulsar.client.admin.Brokers
Get the list of active brokers in the local cluster.
getActiveBrokers(String) - Method in interface org.apache.pulsar.client.admin.Brokers
Get the list of active brokers in the cluster.
getActiveBrokersAsync() - Method in interface org.apache.pulsar.client.admin.Brokers
Get the list of active brokers in the local cluster asynchronously.
getActiveBrokersAsync(String) - Method in interface org.apache.pulsar.client.admin.Brokers
Get the list of active brokers in the cluster asynchronously.
getActiveConsumerName() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
The name of the consumer that is active for single active consumer subscriptions i.e.
getAddress() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats
Address of this consumer.
getAddress() - Method in interface org.apache.pulsar.common.policies.data.PublisherStats
Address of this publisher.
getAdminRoles() - Method in interface org.apache.pulsar.common.policies.data.TenantInfo
 
getAllDynamicConfigurations() - Method in interface org.apache.pulsar.client.admin.Brokers
Get values of all overridden dynamic-configs.
getAllDynamicConfigurationsAsync() - Method in interface org.apache.pulsar.client.admin.Brokers
Get values of all overridden dynamic-configs asynchronously.
getAllocatorStats(String) - Method in interface org.apache.pulsar.client.admin.BrokerStats
Get the stats for the Netty allocator.
getAllocatorStatsAsync(String) - Method in interface org.apache.pulsar.client.admin.BrokerStats
Get the stats for the Netty allocator asynchronously.
getAllowedClusters() - Method in interface org.apache.pulsar.common.policies.data.TenantInfo
 
getAllSchemas(String) - Method in interface org.apache.pulsar.client.admin.Schemas
Get all version schemas topic.
getAllSchemasAsync(String) - Method in interface org.apache.pulsar.client.admin.Schemas
Get all version schemas topic asynchronously.
getAntiAffinityNamespaces(String, String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get all namespaces that grouped with given anti-affinity group.
getAntiAffinityNamespacesAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get all namespaces that grouped with given anti-affinity group asynchronously.
getAssignments() - Method in interface org.apache.pulsar.client.admin.Worker
Get the function assignment among the cluster.
getAssignmentsAsync() - Method in interface org.apache.pulsar.client.admin.Worker
Get the function assignment among the cluster asynchronously.
getAuthenticationParameters() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
 
getAuthenticationPlugin() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
 
getAutoFailoverPolicy() - Method in interface org.apache.pulsar.common.policies.data.NamespaceIsolationData
 
getAutoSubscriptionCreation(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the autoSubscriptionCreation info within a namespace.
getAutoSubscriptionCreation(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get the autoSubscriptionCreation info within a topic.
getAutoSubscriptionCreationAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the autoSubscriptionCreation info within a namespace asynchronously.
getAutoSubscriptionCreationAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get the autoSubscriptionCreation info within a topic asynchronously.
getAutoTopicCreation(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the autoTopicCreation info within a namespace.
getAutoTopicCreationAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the autoTopicCreation info within a namespace asynchronously.
getAvailablePermits() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats
Number of available message permits for the consumer.
getAverageMsgSize() - Method in interface org.apache.pulsar.common.policies.data.PublisherStats
Average message size published by this publisher.
getAverageMsgSize() - Method in interface org.apache.pulsar.common.policies.data.TopicStats
Average size of published messages (bytes).
getAvgMessagesPerEntry() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats
Number of average messages per entry for the consumer consumed.
getAvgProcessLatency() - Method in interface org.apache.pulsar.common.policies.data.FunctionInstanceStatsDataBase
 
getAvgProcessLatency() - Method in interface org.apache.pulsar.common.policies.data.FunctionStats
 
getBacklogQuotaMap(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get backlog quota map on a namespace.
getBacklogQuotaMap(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get backlog quota map for a topic.
getBacklogQuotaMap(String) - Method in interface org.apache.pulsar.client.admin.Topics
getBacklogQuotaMap(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get applied backlog quota map for a topic.
getBacklogQuotaMap(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getBacklogQuotaMapAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get backlog quota map on a namespace asynchronously.
getBacklogSize() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
Size of backlog in byte.
getBacklogSize() - Method in interface org.apache.pulsar.common.policies.data.TopicStats
Get estimated total unconsumed or backlog size in bytes.
getBacklogSizeByMessageId(String, MessageId) - Method in interface org.apache.pulsar.client.admin.Topics
Get backlog size by a message ID.
getBacklogSizeByMessageIdAsync(String, MessageId) - Method in interface org.apache.pulsar.client.admin.Topics
Get backlog size by a message ID asynchronously.
getBandwidthIn() - Method in interface org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport
 
getBandwidthOut() - Method in interface org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport
 
getBookie(String) - Method in class org.apache.pulsar.common.policies.data.BookiesRackConfiguration
 
getBookieAffinityGroup(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get bookie affinity group configured for a namespace.
getBookieAffinityGroupAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get bookie affinity group configured for a namespace asynchronously.
getBookieRackInfo(String) - Method in interface org.apache.pulsar.client.admin.Bookies
Gets the rack placement information for a specific bookie in the cluster.
getBookieRackInfoAsync(String) - Method in interface org.apache.pulsar.client.admin.Bookies
Gets the rack placement information for a specific bookie in the cluster asynchronously.
getBookies() - Method in interface org.apache.pulsar.client.admin.Bookies
Gets discovery information for all the bookies in the cluster.
getBookies() - Method in interface org.apache.pulsar.common.policies.data.BookiesClusterInfo
 
getBookiesAsync() - Method in interface org.apache.pulsar.client.admin.Bookies
Gets discovery information for all the bookies in the cluster asynchronously.
getBookiesRackInfo() - Method in interface org.apache.pulsar.client.admin.Bookies
Gets the rack placement information for all the bookies in the cluster.
getBookiesRackInfoAsync() - Method in interface org.apache.pulsar.client.admin.Bookies
Gets the rack placement information for all the bookies in the cluster asynchronously.
getBookkeeperAckQuorum() - Method in class org.apache.pulsar.common.policies.data.PersistencePolicies
 
getBookkeeperAffinityGroupPrimary() - Method in interface org.apache.pulsar.common.policies.data.BookieAffinityGroupData
 
getBookkeeperAffinityGroupSecondary() - Method in interface org.apache.pulsar.common.policies.data.BookieAffinityGroupData
 
getBookkeeperEnsemble() - Method in class org.apache.pulsar.common.policies.data.PersistencePolicies
 
getBookkeeperMetadataServiceUri() - Method in class org.apache.pulsar.common.conf.InternalConfigurationData
 
getBookkeeperWriteQuorum() - Method in class org.apache.pulsar.common.policies.data.PersistencePolicies
 
getBoundaries() - Method in interface org.apache.pulsar.common.policies.data.BundlesData
 
getBrokerAddress() - Method in interface org.apache.pulsar.common.policies.data.BrokerStatus
 
getBrokerClientCertificateFilePath() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
 
getBrokerClientKeyFilePath() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
 
getBrokerClientTlsKeyStore() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
 
getBrokerClientTlsKeyStorePassword() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
 
getBrokerClientTlsKeyStoreType() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
 
getBrokerClientTlsTrustStore() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
 
getBrokerClientTlsTrustStorePassword() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
 
getBrokerClientTlsTrustStoreType() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
 
getBrokerClientTrustCertsFilePath() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
 
getBrokerName() - Method in interface org.apache.pulsar.common.policies.data.BrokerNamespaceIsolationData
 
getBrokers() - Method in interface org.apache.pulsar.common.policies.data.FailureDomain
 
getBrokerServiceUrl() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
 
getBrokerServiceUrlTls() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
 
getBrokersWithNamespaceIsolationPolicy(String) - Method in interface org.apache.pulsar.client.admin.Clusters
Returns list of active brokers with namespace-isolation policies attached to it.
getBrokersWithNamespaceIsolationPolicyAsync(String) - Method in interface org.apache.pulsar.client.admin.Clusters
Returns list of active brokers with namespace-isolation policies attached to it asynchronously.
getBrokerVersionString() - Method in interface org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport
 
getBrokerWithNamespaceIsolationPolicy(String, String) - Method in interface org.apache.pulsar.client.admin.Clusters
Returns active broker with namespace-isolation policies attached to it.
getBrokerWithNamespaceIsolationPolicyAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Clusters
Returns active broker with namespace-isolation policies attached to it asynchronously.
getBuiltInFunctions() - Method in interface org.apache.pulsar.client.admin.Functions
Fetches a list of supported Pulsar Functions currently running in cluster mode.
getBuiltInFunctionsAsync() - Method in interface org.apache.pulsar.client.admin.Functions
Fetches a list of supported Pulsar Functions currently running in cluster mode asynchronously.
getBuiltInSinks() - Method in interface org.apache.pulsar.client.admin.Sinks
Fetches a list of supported Pulsar IO sinks currently running in cluster mode.
getBuiltInSinksAsync() - Method in interface org.apache.pulsar.client.admin.Sinks
Fetches a list of supported Pulsar IO sinks currently running in cluster mode asynchronously.
getBuiltInSources() - Method in interface org.apache.pulsar.client.admin.Sources
Fetches a list of supported Pulsar IO sources currently running in cluster mode.
getBuiltInSourcesAsync() - Method in interface org.apache.pulsar.client.admin.Sources
Fetches a list of supported Pulsar IO sources currently running in cluster mode asynchronously.
getBundleRange(String) - Method in interface org.apache.pulsar.client.admin.Lookup
Get a bundle range of a topic.
getBundleRangeAsync(String) - Method in interface org.apache.pulsar.client.admin.Lookup
Get a bundle range of a topic asynchronously.
getBundles(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the list of bundles.
getBundlesAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the list of bundles asynchronously.
getBundleStats() - Method in interface org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport
 
getBytesInCounter() - Method in interface org.apache.pulsar.common.policies.data.TopicStats
Total bytes published to the topic (bytes).
getBytesOutCounter() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats
Total bytes delivered to consumer (bytes).
getBytesOutCounter() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
Total bytes delivered to consumer (bytes).
getBytesOutCounter() - Method in interface org.apache.pulsar.common.policies.data.TopicStats
Total bytes delivered to consumer (bytes).
getChunkedMessageRate() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats
The total rate of chunked messages delivered to this consumer.
getChunkedMessageRate() - Method in interface org.apache.pulsar.common.policies.data.PublisherStats
The total rate of chunked messages published by this publisher.
getChunkedMessageRate() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
Chunked message dispatch rate.
getClientVersion() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats
Client library version.
getClientVersion() - Method in interface org.apache.pulsar.common.policies.data.PublisherStats
Client library version.
getCluster() - Method in interface org.apache.pulsar.client.admin.Worker
Get List of all workers belonging to this cluster.
getCluster(String) - Method in interface org.apache.pulsar.client.admin.Clusters
Get the configuration data for the specified cluster.
getClusterAsync() - Method in interface org.apache.pulsar.client.admin.Worker
Get List of all workers belonging to this cluster asynchronously.
getClusterAsync(String) - Method in interface org.apache.pulsar.client.admin.Clusters
Get the configuration data for the specified cluster asynchronously.
getClusterLeader() - Method in interface org.apache.pulsar.client.admin.Worker
Get the worker who is the leader of the cluster.
getClusterLeaderAsync() - Method in interface org.apache.pulsar.client.admin.Worker
Get the worker who is the leader of the cluster asynchronously.
getClusters() - Method in interface org.apache.pulsar.client.admin.Clusters
Get the list of clusters.
getClustersAsync() - Method in interface org.apache.pulsar.client.admin.Clusters
Get the list of clusters asynchronously.
getCompaction() - Method in interface org.apache.pulsar.common.policies.data.TopicStats
The compaction stats.
getCompactionThreshold(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the compactionThreshold for a namespace.
getCompactionThreshold(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get the compactionThreshold for a topic.
getCompactionThreshold(String) - Method in interface org.apache.pulsar.client.admin.Topics
getCompactionThreshold(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get the compactionThreshold for a topic.
getCompactionThreshold(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getCompactionThresholdAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the compactionThreshold for a namespace asynchronously.
getCompactionThresholdAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get the compactionThreshold for a topic asynchronously.
getCompactionThresholdAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
getCompactionThresholdAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get the compactionThreshold for a topic asynchronously.
getCompactionThresholdAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getConfigurationMetadataStoreUrl() - Method in class org.apache.pulsar.common.conf.InternalConfigurationData
 
getConfigurationStoreServers() - Method in class org.apache.pulsar.common.conf.InternalConfigurationData
Deprecated.
getConnectedSince() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats
Timestamp of connection.
getConnectedSince() - Method in interface org.apache.pulsar.common.policies.data.PublisherStats
Timestamp of connection.
getConnections() - Method in interface org.apache.pulsar.client.admin.ProxyStats
Returns Connections metrics.
getConnectorsList() - Method in interface org.apache.pulsar.client.admin.Functions
Deprecated.
getConsumerName() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats
Name of the consumer.
getConsumers() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
List of connected consumers on this subscription w/ their stats.
getConsumersAfterMarkDeletePosition() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
This is for Key_Shared subscription to get the recentJoinedConsumers in the Key_Shared subscription.
getCoordinatorInternalStats(int, boolean) - Method in interface org.apache.pulsar.client.admin.Transactions
Get transaction coordinator internal stats.
getCoordinatorInternalStatsAsync(int, boolean) - Method in interface org.apache.pulsar.client.admin.Transactions
Get transaction coordinator internal stats.
getCoordinatorStats() - Method in interface org.apache.pulsar.client.admin.Transactions
Get transaction metadataStore stats.
getCoordinatorStatsAsync() - Method in interface org.apache.pulsar.client.admin.Transactions
Get transaction metadataStore stats.
getCoordinatorStatsById(int) - Method in interface org.apache.pulsar.client.admin.Transactions
Get transaction metadataStore stats.
getCoordinatorStatsByIdAsync(int) - Method in interface org.apache.pulsar.client.admin.Transactions
Get transaction metadataStore stats.
getCpu() - Method in interface org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport
 
getDeduplicationEnabled(String) - Method in interface org.apache.pulsar.client.admin.Topics
getDeduplicationEnabledAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
getDeduplicationSnapshotInterval(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the deduplicationSnapshotInterval for a namespace.
getDeduplicationSnapshotInterval(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get the deduplication snapshot interval for specified topic.
getDeduplicationSnapshotInterval(String) - Method in interface org.apache.pulsar.client.admin.Topics
getDeduplicationSnapshotIntervalAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the deduplicationSnapshotInterval for a namespace asynchronously.
getDeduplicationSnapshotIntervalAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get the deduplication snapshot interval for specified topic asynchronously.
getDeduplicationSnapshotIntervalAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
getDeduplicationStatus() - Method in interface org.apache.pulsar.common.policies.data.TopicStats
 
getDeduplicationStatus(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the deduplication status for all topics within a namespace .
getDeduplicationStatus(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
get deduplication enabled of a topic.
getDeduplicationStatus(String) - Method in interface org.apache.pulsar.client.admin.Topics
getDeduplicationStatus(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
get applied deduplication enabled of a topic.
getDeduplicationStatus(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getDeduplicationStatusAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the deduplication status for all topics within a namespace asynchronously.
getDeduplicationStatusAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
get deduplication enabled of a topic asynchronously.
getDeduplicationStatusAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
getDeduplicationStatusAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
get applied deduplication enabled of a topic asynchronously.
getDeduplicationStatusAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getDefaultNumPartitions() - Method in interface org.apache.pulsar.common.policies.data.AutoTopicCreationOverride
 
getDefaultResourceQuota() - Method in interface org.apache.pulsar.client.admin.ResourceQuotas
Get default resource quota for new resource bundles.
getDefaultResourceQuotaAsync() - Method in interface org.apache.pulsar.client.admin.ResourceQuotas
Get default resource quota for new resource bundles asynchronously.
getDefaultResources() - Static method in class org.apache.pulsar.common.functions.Resources
 
getDelayedDelivery(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the delayed delivery messages for all topics within a namespace.
getDelayedDeliveryAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the delayed delivery messages for all topics within a namespace asynchronously.
getDelayedDeliveryPolicy(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get the delayed delivery policy for a specified topic.
getDelayedDeliveryPolicy(String) - Method in interface org.apache.pulsar.client.admin.Topics
getDelayedDeliveryPolicy(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get the delayed delivery policy applied for a specified topic.
getDelayedDeliveryPolicy(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getDelayedDeliveryPolicyAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get the delayed delivery policy for a specified topic asynchronously.
getDelayedDeliveryPolicyAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
getDelayedDeliveryPolicyAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get the delayed delivery policy applied for a specified topic asynchronously.
getDelayedDeliveryPolicyAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getDelayedMessageIndexSizeInBytes() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
 
getDelayedMessageIndexSizeInBytes() - Method in interface org.apache.pulsar.common.policies.data.TopicStats
 
getDimension(String) - Method in class org.apache.pulsar.common.stats.Metrics
 
getDimensions() - Method in class org.apache.pulsar.common.stats.Metrics
 
getDirectMemory() - Method in interface org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport
 
getDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get message-dispatch-rate (topics under this namespace can dispatch this many messages per second).
getDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get message-dispatch-rate (topic can dispatch this many messages per second).
getDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.Topics
Deprecated.
getDispatchRate(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get applied message-dispatch-rate (topic can dispatch this many messages per second).
getDispatchRate(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getDispatchRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get message-dispatch-rate asynchronously.
getDispatchRateAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get message-dispatch-rate asynchronously.
getDispatchRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
getDispatchRateAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get applied message-dispatch-rate asynchronously.
getDispatchRateAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getDispatchThrottlingRateInByte() - Method in interface org.apache.pulsar.common.policies.data.DispatchRate
 
getDispatchThrottlingRateInMsg() - Method in interface org.apache.pulsar.common.policies.data.DispatchRate
 
getDynamic() - Method in class org.apache.pulsar.common.policies.data.ResourceQuota
 
getDynamicConfigurationNames() - Method in interface org.apache.pulsar.client.admin.Brokers
Get list of updatable configuration name.
getDynamicConfigurationNamesAsync() - Method in interface org.apache.pulsar.client.admin.Brokers
Get list of updatable configuration name asynchronously.
getEarliestMsgPublishTimeInBacklog() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
Get the publish time of the earliest message in the backlog.
getEarliestMsgPublishTimeInBacklogs() - Method in interface org.apache.pulsar.common.policies.data.TopicStats
Get the publish time of the earliest message over all the backlogs.
getEncryptionRequiredStatus(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the encryption required status within a namespace.
getEncryptionRequiredStatusAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the encryption required status within a namespace asynchronously.
getEntryFiltersPerTopic(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get applied entry filters for a topic.
getEntryFiltersPerTopicAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get applied entry filters for a topic asynchronously.
getEnum(String) - Static method in enum class org.apache.pulsar.common.naming.TopicDomain
 
getEnum(String) - Static method in enum class org.apache.pulsar.packages.management.core.common.PackageType
 
getFailureDomain(String, String) - Method in interface org.apache.pulsar.client.admin.Clusters
Get the domain registered into a cluster.
getFailureDomainAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Clusters
Get the domain registered into a cluster asynchronously.
getFailureDomains(String) - Method in interface org.apache.pulsar.client.admin.Clusters
Get all registered domains in cluster.
getFailureDomainsAsync(String) - Method in interface org.apache.pulsar.client.admin.Clusters
Get all registered domains in cluster asynchronously.
getFileSystemProfilePath() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
 
getFileSystemURI() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
 
getFilterAcceptedMsgCount() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
 
getFilterProcessedMsgCount() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
 
getFilterRejectedMsgCount() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
 
getFilterRescheduledMsgCount() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
 
getFirstUnoffloadedMessage() - Method in interface org.apache.pulsar.client.admin.OffloadProcessStatus
 
getFunction(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions
Get the configuration for the specified function.
getFunctionAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions
Get the configuration for the specified function asynchronously.
getFunctions(String, String) - Method in interface org.apache.pulsar.client.admin.Functions
Get the list of functions.
getFunctionsAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Functions
Get the list of functions asynchronously.
getFunctionsStats() - Method in interface org.apache.pulsar.client.admin.Worker
Get all functions stats on a worker.
getFunctionsStatsAsync() - Method in interface org.apache.pulsar.client.admin.Worker
Get all functions stats on a worker asynchronously.
getFunctionState(String, String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions
Fetch the current state associated with a Pulsar Function.
getFunctionStateAsync(String, String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions
Fetch the current state associated with a Pulsar Function asynchronously.
getFunctionStats(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions
Gets the current stats of a function.
getFunctionStats(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Functions
Gets the current stats of a function instance.
getFunctionStatsAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions
Gets the current stats of a function asynchronously.
getFunctionStatsAsync(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Functions
Gets the current stats of a function instance asynchronously.
getFunctionStatus(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions
Gets the current status of a function.
getFunctionStatus(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Functions
Gets the current status of a function instance.
getFunctionStatusAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions
Gets the current status of a function asynchronously.
getFunctionStatusAsync(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Functions
Gets the current status of a function instance asynchronously.
getGcsManagedLedgerOffloadBucket() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
 
getGcsManagedLedgerOffloadMaxBlockSizeInBytes() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
 
getGcsManagedLedgerOffloadReadBufferSizeInBytes() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
 
getGcsManagedLedgerOffloadRegion() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
 
getGcsManagedLedgerOffloadServiceAccountKeyFile() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
 
getHostname() - Method in interface org.apache.pulsar.common.policies.data.BookieInfo
 
getHttpError() - Method in exception org.apache.pulsar.client.admin.PulsarAdminException
 
getInactiveTopicPolicies(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the inactive deletion strategy for all topics within a namespace synchronously.
getInactiveTopicPolicies(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
get inactive topic policies of a topic.
getInactiveTopicPolicies(String) - Method in interface org.apache.pulsar.client.admin.Topics
getInactiveTopicPolicies(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get inactive topic policies applied for a topic.
getInactiveTopicPolicies(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getInactiveTopicPoliciesAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the inactive deletion strategy for all topics within a namespace asynchronously.
getInactiveTopicPoliciesAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
get inactive topic policies of a topic asynchronously.
getInactiveTopicPoliciesAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
getInactiveTopicPoliciesAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get inactive topic policies applied for a topic asynchronously.
getInactiveTopicPoliciesAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getInboundConnectedSince() - Method in interface org.apache.pulsar.common.policies.data.ReplicatorStats
Timestamp of incoming connection establishment time.
getInboundConnection() - Method in interface org.apache.pulsar.common.policies.data.ReplicatorStats
Address of incoming replication connection.
getInstanceId() - Method in interface org.apache.pulsar.common.policies.data.FunctionInstanceStats
 
getInstances() - Method in interface org.apache.pulsar.common.policies.data.FunctionStats
 
getInternalConfigurationData() - Method in interface org.apache.pulsar.client.admin.Brokers
Get the internal configuration data.
getInternalConfigurationDataAsync() - Method in interface org.apache.pulsar.client.admin.Brokers
Get the internal configuration data asynchronously.
getInternalInfo(String) - Method in interface org.apache.pulsar.client.admin.Topics
Get a JSON representation of the topic metadata stored in ZooKeeper.
getInternalInfoAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
Get a JSON representation of the topic metadata stored in ZooKeeper.
getInternalStats(String) - Method in interface org.apache.pulsar.client.admin.NonPersistentTopics
Deprecated.
Get the internal stats for the topic.
getInternalStats(String) - Method in interface org.apache.pulsar.client.admin.Topics
Get the internal stats for the topic.
getInternalStats(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
Get the internal stats for the topic.
getInternalStatsAsync(String) - Method in interface org.apache.pulsar.client.admin.NonPersistentTopics
Deprecated.
Get the internal stats for the topic asynchronously.
getInternalStatsAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
Get the internal stats for the topic asynchronously.
getInternalStatsAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
Get the internal stats for the topic asynchronously.
getIsAllowAutoUpdateSchema(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get whether allow auto update schema.
getIsAllowAutoUpdateSchemaAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get whether allow auto update schema asynchronously.
getKeyHashRanges() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats
Hash ranges assigned to this consumer if is Key_Shared sub mode.
getKeySharedMode() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
Whether the Key_Shared subscription mode is AUTO_SPLIT or STICKY.
getLastAckedTimestamp() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats
 
getLastAckedTimestamp() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
Last acked message timestamp.
getLastCompactionDurationTimeInMills() - Method in interface org.apache.pulsar.common.policies.data.CompactionStats
The duration time of last compaction.
getLastCompactionFailedTimestamp() - Method in interface org.apache.pulsar.common.policies.data.CompactionStats
The timestamp of last failed compaction.
getLastCompactionRemovedEventCount() - Method in interface org.apache.pulsar.common.policies.data.CompactionStats
The removed event count of last compaction.
getLastCompactionSucceedTimestamp() - Method in interface org.apache.pulsar.common.policies.data.CompactionStats
The timestamp of last succeed compaction.
getLastConsumedFlowTimestamp() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats
 
getLastConsumedFlowTimestamp() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
Last received consume flow command timestamp.
getLastConsumedTimestamp() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats
 
getLastConsumedTimestamp() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
Last consume message timestamp.
getLastError() - Method in interface org.apache.pulsar.client.admin.OffloadProcessStatus
 
getLastExpireTimestamp() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
Last message expire execution timestamp.
getLastInvocation() - Method in interface org.apache.pulsar.common.policies.data.FunctionInstanceStatsData
 
getLastInvocation() - Method in interface org.apache.pulsar.common.policies.data.FunctionStats
 
getLastMarkDeleteAdvancedTimestamp() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
Last MarkDelete position advanced timesetamp.
getLastMessageId(String) - Method in interface org.apache.pulsar.client.admin.Topics
Get the last commit message Id of a topic.
getLastMessageIdAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
Get the last commit message Id of a topic asynchronously.
getLastUpdate() - Method in interface org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport
 
getLeaderBroker() - Method in interface org.apache.pulsar.client.admin.Brokers
Get the information of the leader broker.
getLeaderBrokerAsync() - Method in interface org.apache.pulsar.client.admin.Brokers
Get the service url of the leader broker asynchronously.
getLedgersRootPath() - Method in class org.apache.pulsar.common.conf.InternalConfigurationData
Deprecated. 
getLimit() - Method in interface org.apache.pulsar.common.policies.data.BacklogQuota
Deprecated.
getLimit() - Method in class org.apache.pulsar.common.policies.data.impl.BacklogQuotaImpl
Deprecated.
getLimitSize() - Method in interface org.apache.pulsar.common.policies.data.BacklogQuota
Gets quota limit in size.
getLimitSize() - Method in class org.apache.pulsar.common.policies.data.impl.BacklogQuotaImpl
 
getLimitTime() - Method in interface org.apache.pulsar.common.policies.data.BacklogQuota
Gets quota limit in time.
getLimitTime() - Method in class org.apache.pulsar.common.policies.data.impl.BacklogQuotaImpl
 
getList(String) - Method in interface org.apache.pulsar.client.admin.NonPersistentTopics
Deprecated.
Get list of topics exist into given namespace.
getList(String) - Method in interface org.apache.pulsar.client.admin.Topics
Get the both persistent and non-persistent topics under a namespace.
getList(String, TopicDomain) - Method in interface org.apache.pulsar.client.admin.Topics
Get the list of topics under a namespace.
getList(String, TopicDomain, Map<Topics.QueryParam, Object>) - Method in interface org.apache.pulsar.client.admin.Topics
getList(String, TopicDomain, ListTopicsOptions) - Method in interface org.apache.pulsar.client.admin.Topics
Get the list of topics under a namespace.
getListAsync(String) - Method in interface org.apache.pulsar.client.admin.NonPersistentTopics
Deprecated.
Get list of topics exist into given namespace asynchronously.
getListAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
Get both persistent and non-persistent topics under a namespace asynchronously.
getListAsync(String, TopicDomain) - Method in interface org.apache.pulsar.client.admin.Topics
Get the list of topics under a namespace asynchronously.
getListAsync(String, TopicDomain, Map<Topics.QueryParam, Object>) - Method in interface org.apache.pulsar.client.admin.Topics
getListAsync(String, TopicDomain, ListTopicsOptions) - Method in interface org.apache.pulsar.client.admin.Topics
Get the list of topics under a namespace asynchronously.
getListenerName() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
 
getListInBundle(String, String) - Method in interface org.apache.pulsar.client.admin.NonPersistentTopics
Deprecated.
Get list of topics exist into given bundle.
getListInBundle(String, String) - Method in interface org.apache.pulsar.client.admin.Topics
Get list of topics exist into given bundle.
getListInBundleAsync(String, String) - Method in interface org.apache.pulsar.client.admin.NonPersistentTopics
Deprecated.
Get list of topics exist into given bundle asynchronously.
getListInBundleAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Topics
Get list of topics exist into given bundle asynchronously.
getLoadFactor() - Method in interface org.apache.pulsar.common.policies.data.BrokerStatus
 
getLoadManagerClassName() - Method in interface org.apache.pulsar.policies.data.loadbalancer.ServiceLookupData
 
getLoadReport() - Method in interface org.apache.pulsar.client.admin.BrokerStats
Get load for this broker.
getLoadReportAsync() - Method in interface org.apache.pulsar.client.admin.BrokerStats
Get load for this broker asynchronously.
getManagedLedgerMaxMarkDeleteRate() - Method in class org.apache.pulsar.common.policies.data.PersistencePolicies
 
getManagedLedgerOffloadBucket() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
 
getManagedLedgerOffloadDeletionLagInMillis() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
 
getManagedLedgerOffloadDriver() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
 
getManagedLedgerOffloadedReadPriority() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
 
getManagedLedgerOffloadMaxBlockSizeInBytes() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
 
getManagedLedgerOffloadMaxThreads() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
 
getManagedLedgerOffloadPrefetchRounds() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
 
getManagedLedgerOffloadReadBufferSizeInBytes() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
 
getManagedLedgerOffloadRegion() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
 
getManagedLedgerOffloadServiceEndpoint() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
 
getManagedLedgerOffloadThresholdInBytes() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
 
getManagedLedgerOffloadThresholdInSeconds() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
 
getMaxConsumers(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get the max number of consumer for specified topic.
getMaxConsumers(String) - Method in interface org.apache.pulsar.client.admin.Topics
Deprecated.
getMaxConsumers(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get the max number of consumer applied for specified topic.
getMaxConsumers(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getMaxConsumersAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get the max number of consumer for specified topic asynchronously.
getMaxConsumersAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
getMaxConsumersAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get the max number of consumer applied for specified topic asynchronously.
getMaxConsumersAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getMaxConsumersPerSubscription(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the maxConsumersPerSubscription for a namespace.
getMaxConsumersPerSubscription(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get the maxConsumersPerSubscription for a topic.
getMaxConsumersPerSubscription(String) - Method in interface org.apache.pulsar.client.admin.Topics
getMaxConsumersPerSubscriptionAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the maxConsumersPerSubscription for a namespace asynchronously.
getMaxConsumersPerSubscriptionAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get the maxConsumersPerSubscription for a topic asynchronously.
getMaxConsumersPerSubscriptionAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
getMaxConsumersPerTopic(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the maxProducersPerTopic for a namespace.
getMaxConsumersPerTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the maxProducersPerTopic for a namespace asynchronously.
getMaxMessageSize(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get the max message size for specified topic.
getMaxMessageSize(String) - Method in interface org.apache.pulsar.client.admin.Topics
Deprecated.
getMaxMessageSizeAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get the max message size for specified topic asynchronously.
getMaxMessageSizeAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
getMaxProducers(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get the max number of producer for specified topic.
getMaxProducers(String) - Method in interface org.apache.pulsar.client.admin.Topics
Deprecated.
getMaxProducers(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get the max number of producer applied for specified topic.
getMaxProducers(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getMaxProducersAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get the max number of producer for specified topic asynchronously.
getMaxProducersAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
getMaxProducersAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get the max number of producer applied for specified topic asynchronously.
getMaxProducersAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getMaxProducersPerTopic(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the maxProducersPerTopic for a namespace.
getMaxProducersPerTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the maxProducersPerTopic for a namespace asynchronously.
getMaxSubscriptionsPerTopic(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the maxSubscriptionsPerTopic for a namespace.
getMaxSubscriptionsPerTopic(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get the max number of subscriptions for specified topic.
getMaxSubscriptionsPerTopic(String) - Method in interface org.apache.pulsar.client.admin.Topics
getMaxSubscriptionsPerTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the maxSubscriptionsPerTopic for a namespace asynchronously.
getMaxSubscriptionsPerTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get the max number of subscriptions for specified topic asynchronously.
getMaxSubscriptionsPerTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
getMaxTopicsPerNamespace(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get maxTopicsPerNamespace for a namespace.
getMaxTopicsPerNamespaceAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get maxTopicsPerNamespace for a namespace asynchronously.
getMaxUnackedMessagesOnConsumer(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get max unacked messages on a consumer of a topic.
getMaxUnackedMessagesOnConsumer(String) - Method in interface org.apache.pulsar.client.admin.Topics
getMaxUnackedMessagesOnConsumer(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
get applied max unacked messages on consumer of a topic.
getMaxUnackedMessagesOnConsumer(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getMaxUnackedMessagesOnConsumerAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
get max unacked messages on consumer of a topic asynchronously.
getMaxUnackedMessagesOnConsumerAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
getMaxUnackedMessagesOnConsumerAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
get applied max unacked messages on consumer of a topic asynchronously.
getMaxUnackedMessagesOnConsumerAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getMaxUnackedMessagesOnSubscription(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
get max unacked messages on subscription of a topic.
getMaxUnackedMessagesOnSubscription(String) - Method in interface org.apache.pulsar.client.admin.Topics
getMaxUnackedMessagesOnSubscription(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
get max unacked messages on subscription of a topic.
getMaxUnackedMessagesOnSubscription(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getMaxUnackedMessagesOnSubscriptionAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
get max unacked messages on subscription of a topic asynchronously.
getMaxUnackedMessagesOnSubscriptionAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
getMaxUnackedMessagesOnSubscriptionAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
get max unacked messages on subscription of a topic asynchronously.
getMaxUnackedMessagesOnSubscriptionAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getMaxUnackedMessagesPerConsumer(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the maxUnackedMessagesPerConsumer for a namespace.
getMaxUnackedMessagesPerConsumerAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the maxUnackedMessagesPerConsumer for a namespace asynchronously.
getMaxUnackedMessagesPerSubscription(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the maxUnackedMessagesPerSubscription for a namespace.
getMaxUnackedMessagesPerSubscriptionAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the maxUnackedMessagesPerSubscription for a namespace asynchronously.
getMBeans() - Method in interface org.apache.pulsar.client.admin.BrokerStats
Requests JSON string server mbean dump.
getMBeansAsync() - Method in interface org.apache.pulsar.client.admin.BrokerStats
Requests JSON string server mbean dump asynchronously.
getMemory() - Method in interface org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport
 
getMessageAckRate() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats
Total rate of message ack(msg/s).
getMessageAckRate() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
Total rate of message ack(msg/s).
getMessageById(String, long, long) - Method in interface org.apache.pulsar.client.admin.Topics
Get a message by its messageId via a topic subscription.
getMessageByIdAsync(String, long, long) - Method in interface org.apache.pulsar.client.admin.Topics
Get a message by its messageId via a topic subscription asynchronously.
getMessageIdByTimestamp(String, long) - Method in interface org.apache.pulsar.client.admin.Topics
Get message ID published at or just after this absolute timestamp (in ms).
getMessageIdByTimestampAsync(String, long) - Method in interface org.apache.pulsar.client.admin.Topics
Get message ID published at or just after this absolute timestamp (in ms) asynchronously.
getMessageTTL(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get message TTL for a topic.
getMessageTTL(String) - Method in interface org.apache.pulsar.client.admin.Topics
Deprecated.
getMessageTTL(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get message TTL applied for a topic.
getMessageTTL(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getMetadata() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats
Metadata (key/value strings) associated with this consumer.
getMetadata() - Method in interface org.apache.pulsar.common.policies.data.PartitionedTopicStats
 
getMetadata() - Method in interface org.apache.pulsar.common.policies.data.PublisherStats
Metadata (key/value strings) associated with this publisher.
getMetadata(String) - Method in interface org.apache.pulsar.client.admin.Packages
Get a package metadata information.
getMetadataAsync(String) - Method in interface org.apache.pulsar.client.admin.Packages
Get a package metadata information asynchronously.
getMetadataStoreUrl() - Method in class org.apache.pulsar.common.conf.InternalConfigurationData
 
getMetrics() - Method in interface org.apache.pulsar.client.admin.BrokerStats
Returns Monitoring metrics.
getMetrics() - Method in interface org.apache.pulsar.client.admin.Worker
Get worker metrics.
getMetrics() - Method in interface org.apache.pulsar.common.policies.data.FunctionInstanceStats
 
getMetrics() - Method in class org.apache.pulsar.common.stats.Metrics
 
getMetricsAsync() - Method in interface org.apache.pulsar.client.admin.BrokerStats
Returns Monitoring metrics asynchronously.
getMetricsAsync() - Method in interface org.apache.pulsar.client.admin.Worker
Get worker metrics asynchronously.
getMigratedClusterUrl() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
 
getMsgBacklog() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
Number of entries in the subscription backlog.
getMsgBacklogNoDelayed() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
Number of entries in the subscription backlog that do not contain the delay messages.
getMsgDelayed() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
Number of delayed messages currently being tracked.
getMsgDropRate() - Method in interface org.apache.pulsar.common.policies.data.NonPersistentPublisherStats
for non-persistent topic: broker drops msg if publisher publishes messages more than configured max inflight messages per connection.
getMsgDropRate() - Method in interface org.apache.pulsar.common.policies.data.NonPersistentReplicatorStats
for non-persistent topic: broker drops msg for replicator if replicator connection is not writable.
getMsgDropRate() - Method in interface org.apache.pulsar.common.policies.data.NonPersistentSubscriptionStats
for non-persistent topic: broker drops msg for subscription if none of the consumer available for message delivery.
getMsgDropRate() - Method in interface org.apache.pulsar.common.policies.data.NonPersistentTopicStats
for non-persistent topic: broker drops msg if publisher publishes messages more than configured max inflight messages per connection.
getMsgInCounter() - Method in interface org.apache.pulsar.common.policies.data.TopicStats
Total messages published to the topic (msg).
getMsgOutCounter() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats
Total messages delivered to consumer (msg).
getMsgOutCounter() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
Total messages delivered to consumer (msg).
getMsgOutCounter() - Method in interface org.apache.pulsar.common.policies.data.TopicStats
Total messages delivered to consumer (msg).
getMsgRateExpired() - Method in interface org.apache.pulsar.common.policies.data.ReplicatorStats
Total rate of messages expired (msg/s).
getMsgRateExpired() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
Total rate of messages expired on this subscription (msg/s).
getMsgRateIn() - Method in interface org.apache.pulsar.common.policies.data.PublisherStats
Total rate of messages published by this publisher (msg/s).
getMsgRateIn() - Method in interface org.apache.pulsar.common.policies.data.ReplicatorStats
Total rate of messages received from the remote cluster (msg/s).
getMsgRateIn() - Method in interface org.apache.pulsar.common.policies.data.TopicStats
Total rate of messages published on the topic (msg/s).
getMsgRateIn() - Method in interface org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport
 
getMsgRateOut() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats
Total rate of messages delivered to the consumer (msg/s).
getMsgRateOut() - Method in interface org.apache.pulsar.common.policies.data.ReplicatorStats
Total rate of messages delivered to the replication-subscriber (msg/s).
getMsgRateOut() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
Total rate of messages delivered on this subscription (msg/s).
getMsgRateOut() - Method in interface org.apache.pulsar.common.policies.data.TopicStats
Total rate of messages dispatched for the topic (msg/s).
getMsgRateOut() - Method in interface org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport
 
getMsgRateRedeliver() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats
Total rate of messages redelivered by this consumer (msg/s).
getMsgRateRedeliver() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
Total rate of messages redelivered on this subscription (msg/s).
getMsgThroughputIn() - Method in interface org.apache.pulsar.common.policies.data.PublisherStats
Total throughput of messages published by this publisher (byte/s).
getMsgThroughputIn() - Method in interface org.apache.pulsar.common.policies.data.ReplicatorStats
Total throughput received from the remote cluster (bytes/s).
getMsgThroughputIn() - Method in interface org.apache.pulsar.common.policies.data.TopicStats
Total throughput of messages published on the topic (byte/s).
getMsgThroughputIn() - Method in interface org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport
 
getMsgThroughputOut() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats
Total throughput delivered to the consumer (bytes/s).
getMsgThroughputOut() - Method in interface org.apache.pulsar.common.policies.data.ReplicatorStats
Total throughput delivered to the replication-subscriber (bytes/s).
getMsgThroughputOut() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
Total throughput delivered on this subscription (bytes/s).
getMsgThroughputOut() - Method in interface org.apache.pulsar.common.policies.data.TopicStats
Total throughput of messages dispatched for the topic (byte/s).
getMsgThroughputOut() - Method in interface org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport
 
getNamespaceAntiAffinityGroup(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get anti-affinity group name for a namespace.
getNamespaceAntiAffinityGroupAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get anti-affinity group name for a namespace asynchronously.
getNamespaceAuthentication() - Method in interface org.apache.pulsar.common.policies.data.AuthPolicies
 
getNamespaceBundleResourceQuota(String, String) - Method in interface org.apache.pulsar.client.admin.ResourceQuotas
Get resource quota of a namespace bundle.
getNamespaceBundleResourceQuotaAsync(String, String) - Method in interface org.apache.pulsar.client.admin.ResourceQuotas
Get resource quota of a namespace bundle asynchronously.
getNamespaceEntryFilters(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get entry filters for a namespace.
getNamespaceEntryFiltersAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get entry filters for a namespace asynchronously.
getNamespaceIsolationPolicies(String) - Method in interface org.apache.pulsar.client.admin.Clusters
Get the namespace isolation policies of a cluster.
getNamespaceIsolationPoliciesAsync(String) - Method in interface org.apache.pulsar.client.admin.Clusters
Get the namespace isolation policies of a cluster asynchronously.
getNamespaceIsolationPolicy(String, String) - Method in interface org.apache.pulsar.client.admin.Clusters
Get a single namespace isolation policy for a cluster.
getNamespaceIsolationPolicyAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Clusters
Get a single namespace isolation policy for a cluster asynchronously.
getNamespaceMessageTTL(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the message TTL for a namespace.
getNamespaceMessageTTLAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the message TTL for a namespace asynchronously.
getNamespaceRegex() - Method in interface org.apache.pulsar.common.policies.data.BrokerNamespaceIsolationData
 
getNamespaceReplicationClusters(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the replication clusters for a namespace.
getNamespaceReplicationClustersAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the replication clusters for a namespace asynchronously.
getNamespaceResourceGroup(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the ResourceGroup for a namespace.
getNamespaceResourceGroupAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the ResourceGroup for a namespace asynchronously.
getNamespaces() - Method in interface org.apache.pulsar.common.policies.data.NamespaceIsolationData
 
getNamespaces(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the list of namespaces.
getNamespaces(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Deprecated.
getNamespacesAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the list of namespaces asynchronously.
getNonContiguousDeletedMessagesRanges() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
The number of non-contiguous deleted messages ranges.
getNonContiguousDeletedMessagesRanges() - Method in interface org.apache.pulsar.common.policies.data.TopicStats
The number of non-contiguous deleted messages ranges.
getNonContiguousDeletedMessagesRangesSerializedSize() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
The serialized size of non-contiguous deleted messages ranges.
getNonContiguousDeletedMessagesRangesSerializedSize() - Method in interface org.apache.pulsar.common.policies.data.TopicStats
The serialized size of non-contiguous deleted messages ranges.
getNumBundles() - Method in interface org.apache.pulsar.common.policies.data.BundlesData
 
getNumBundles() - Method in interface org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport
 
getNumConsumers() - Method in interface org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport
 
getNumProducers() - Method in interface org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport
 
getNumTopics() - Method in interface org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport
 
getOffloadDeleteLagMs(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the offload deletion lag for a namespace, in milliseconds.
getOffloadDeleteLagMsAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the offload deletion lag asynchronously for a namespace, in milliseconds.
getOffloadedStorageSize() - Method in interface org.apache.pulsar.common.policies.data.TopicStats
Space used to store the offloaded messages for the topic/.
getOffloadersDirectory() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
 
getOffloadPolicies(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the offload configuration for a namespace.
getOffloadPolicies(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
get offload policies of a topic.
getOffloadPolicies(String) - Method in interface org.apache.pulsar.client.admin.Topics
getOffloadPolicies(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
get applied offload policies of a topic.
getOffloadPolicies(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getOffloadPoliciesAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the offload configuration for a namespace asynchronously.
getOffloadPoliciesAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
get offload policies of a topic asynchronously.
getOffloadPoliciesAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
getOffloadPoliciesAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
get applied offload policies of a topic asynchronously.
getOffloadPoliciesAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getOffloadThreshold(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the offloadThreshold for a namespace.
getOffloadThresholdAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the offloadThreshold for a namespace asynchronously.
getOffloadThresholdInSeconds(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the offloadThresholdInSeconds for a namespace.
getOffloadThresholdInSecondsAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the offloadThresholdInSeconds for a namespace.
getOneMin() - Method in interface org.apache.pulsar.common.policies.data.FunctionInstanceStatsData
 
getOneMin() - Method in interface org.apache.pulsar.common.policies.data.FunctionStats
 
getOutboundConnectedSince() - Method in interface org.apache.pulsar.common.policies.data.ReplicatorStats
Timestamp of outbound connection establishment time.
getOutboundConnection() - Method in interface org.apache.pulsar.common.policies.data.ReplicatorStats
Address of outbound replication connection.
getOwnedNamespaces(String, String) - Method in interface org.apache.pulsar.client.admin.Brokers
Get the map of owned namespaces and their status from a single broker in the cluster.
getOwnedNamespacesAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Brokers
Get the map of owned namespaces and their status from a single broker in the cluster asynchronously.
getOwnerBroker() - Method in interface org.apache.pulsar.common.policies.data.TopicStats
The broker that owns this topic.
getParameters() - Method in interface org.apache.pulsar.common.policies.data.AutoFailoverPolicyData
 
getPartitionedInternalStats(String) - Method in interface org.apache.pulsar.client.admin.Topics
Get the stats for the partitioned topic.
getPartitionedInternalStatsAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
Get the stats-internal for the partitioned topic asynchronously.
getPartitionedStats(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
 
getPartitionedStats(String, boolean, boolean, boolean, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
Get the stats for the partitioned topic
getPartitionedStatsAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
 
getPartitionedStatsAsync(String, boolean, boolean, boolean, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
Get the stats for the partitioned topic asynchronously.
getPartitionedTopicList(String) - Method in interface org.apache.pulsar.client.admin.Topics
Get the list of partitioned topics under a namespace.
getPartitionedTopicList(String, ListTopicsOptions) - Method in interface org.apache.pulsar.client.admin.Topics
Get the list of partitioned topics under a namespace.
getPartitionedTopicListAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
Get the list of partitioned topics under a namespace asynchronously.
getPartitionedTopicListAsync(String, ListTopicsOptions) - Method in interface org.apache.pulsar.client.admin.Topics
Get the list of partitioned topics under a namespace asynchronously.
getPartitionedTopicMetadata(String) - Method in interface org.apache.pulsar.client.admin.NonPersistentTopics
Deprecated.
Get metadata of a partitioned topic.
getPartitionedTopicMetadata(String) - Method in interface org.apache.pulsar.client.admin.Topics
Get metadata of a partitioned topic.
getPartitionedTopicMetadataAsync(String) - Method in interface org.apache.pulsar.client.admin.NonPersistentTopics
Deprecated.
Get metadata of a partitioned topic asynchronously.
getPartitionedTopicMetadataAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
Get metadata of a partitioned topic asynchronously.
getPartitions() - Method in interface org.apache.pulsar.common.policies.data.NonPersistentPartitionedTopicStats
 
getPartitions() - Method in interface org.apache.pulsar.common.policies.data.PartitionedTopicStats
 
getPeerClusterNames() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
 
getPeerClusterNames(String) - Method in interface org.apache.pulsar.client.admin.Clusters
Get peer-cluster names.
getPeerClusterNamesAsync(String) - Method in interface org.apache.pulsar.client.admin.Clusters
Get peer-cluster names asynchronously.
getPendingAckInternalStats(String, String, boolean) - Method in interface org.apache.pulsar.client.admin.Transactions
Get pending ack internal stats.
getPendingAckInternalStatsAsync(String, String, boolean) - Method in interface org.apache.pulsar.client.admin.Transactions
Get pending ack internal stats.
getPendingAckStats(String, String) - Method in interface org.apache.pulsar.client.admin.Transactions
Get transaction pending ack stats.
getPendingAckStats(String, String, boolean) - Method in interface org.apache.pulsar.client.admin.Transactions
Get transaction pending ack stats.
getPendingAckStatsAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Transactions
Get transaction pending ack stats.
getPendingAckStatsAsync(String, String, boolean) - Method in interface org.apache.pulsar.client.admin.Transactions
Get transaction pending ack stats.
getPendingBookieOpsStats() - Method in interface org.apache.pulsar.client.admin.BrokerStats
Get pending bookie client op stats by namespace.
getPendingBookieOpsStatsAsync() - Method in interface org.apache.pulsar.client.admin.BrokerStats
Get pending bookie client op stats by namespace asynchronously.
getPermissionOnSubscription(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get permission to role to access subscription's admin-api.
getPermissionOnSubscriptionAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get permission to role to access subscription's admin-api asynchronously.
getPermissions(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get permissions on a namespace.
getPermissions(String) - Method in interface org.apache.pulsar.client.admin.Topics
Get permissions on a topic.
getPermissionsAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get permissions on a namespace asynchronously.
getPermissionsAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
Get permissions on a topic asynchronously.
getPersistence(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the persistence configuration for a namespace.
getPersistence(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get the configuration of persistence policies for specified topic.
getPersistence(String) - Method in interface org.apache.pulsar.client.admin.Topics
Deprecated.
getPersistence(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get the applied configuration of persistence policies for specified topic.
getPersistence(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getPersistenceAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the persistence configuration for a namespace asynchronously.
getPersistenceAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get the configuration of persistence policies for specified topic asynchronously.
getPersistenceAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
getPersistenceAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get the applied configuration of persistence policies for specified topic asynchronously.
getPersistenceAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getPolicies(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get policies for a namespace.
getPoliciesAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get policies for a namespace asynchronously.
getPolicy() - Method in interface org.apache.pulsar.common.policies.data.BacklogQuota
 
getPolicy() - Method in class org.apache.pulsar.common.policies.data.impl.BacklogQuotaImpl
 
getPolicyName() - Method in interface org.apache.pulsar.common.policies.data.BrokerNamespaceIsolationData
 
getPolicyType() - Method in interface org.apache.pulsar.common.policies.data.AutoFailoverPolicyData
 
getPositionStatsInPendingAck(String, String, Long, Long, Integer) - Method in interface org.apache.pulsar.client.admin.Transactions
Get the position stats in transaction pending ack.
getPositionStatsInPendingAckAsync(String, String, Long, Long, Integer) - Method in interface org.apache.pulsar.client.admin.Transactions
Get the position stats in transaction pending ack.
getPrimary() - Method in interface org.apache.pulsar.common.policies.data.NamespaceIsolationData
 
getProcessedSuccessfullyTotal() - Method in interface org.apache.pulsar.common.policies.data.FunctionInstanceStatsDataBase
 
getProcessedSuccessfullyTotal() - Method in interface org.apache.pulsar.common.policies.data.FunctionStats
 
getProducerId() - Method in interface org.apache.pulsar.common.policies.data.PublisherStats
Id of this publisher.
getProducerName() - Method in interface org.apache.pulsar.common.policies.data.PublisherStats
Producer name.
getProperties() - Method in interface org.apache.pulsar.client.admin.Properties
Deprecated.
Get the list of properties.
getProperties(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get all properties of a namespace.
getProperties(String) - Method in interface org.apache.pulsar.client.admin.Topics
Get properties of a topic.
getPropertiesAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get all properties of a namespace asynchronously.
getPropertiesAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
Get properties of a topic asynchronously.
getProperty(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get property value for a given key.
getPropertyAdmin(String) - Method in interface org.apache.pulsar.client.admin.Properties
Deprecated.
Get the config of the property.
getPropertyAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get property value for a given key.
getProtocol(String) - Method in interface org.apache.pulsar.policies.data.loadbalancer.ServiceLookupData
Get the protocol data of the given protocol.
getProtocols() - Method in interface org.apache.pulsar.policies.data.loadbalancer.ServiceLookupData
Get all the protocols advertised by the broker.
getProxyProtocol() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
 
getProxyServiceUrl() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
 
getPublishers() - Method in interface org.apache.pulsar.common.policies.data.NonPersistentTopicStats
List of connected publishers on this topic w/ their stats.
getPublishers() - Method in interface org.apache.pulsar.common.policies.data.TopicStats
List of connected publishers on this topic w/ their stats.
getPublishRate(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get message-publish-rate (topics under this namespace can publish this many messages per second).
getPublishRate(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get message-publish-rate (topics can publish this many messages per second).
getPublishRate(String) - Method in interface org.apache.pulsar.client.admin.Topics
Deprecated.
getPublishRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get message-publish-rate (topics under this namespace can publish this many messages per second) asynchronously.
getPublishRateAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get message-publish-rate (topics can publish this many messages per second) asynchronously.
getPublishRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
getPulsarServiceUrl() - Method in interface org.apache.pulsar.policies.data.loadbalancer.ServiceLookupData
 
getPulsarServiceUrlTls() - Method in interface org.apache.pulsar.policies.data.loadbalancer.ServiceLookupData
 
getRack() - Method in interface org.apache.pulsar.common.policies.data.BookieInfo
 
getRatePeriodInSecond() - Method in interface org.apache.pulsar.common.policies.data.DispatchRate
 
getReadPositionWhenJoining() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats
The read position of the cursor when the consumer joining.
getReceivedTotal() - Method in interface org.apache.pulsar.common.policies.data.FunctionInstanceStatsDataBase
 
getReceivedTotal() - Method in interface org.apache.pulsar.common.policies.data.FunctionStats
 
getReplicatedSubscriptionStatus(String, String) - Method in interface org.apache.pulsar.client.admin.Topics
Get replicated subscription status on a topic.
getReplicatedSubscriptionStatusAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Topics
Get replicated subscription status on a topic asynchronously.
getReplication() - Method in interface org.apache.pulsar.common.policies.data.NonPersistentTopicStats
Map of replication statistics by remote cluster context.
getReplication() - Method in interface org.apache.pulsar.common.policies.data.TopicStats
Map of replication statistics by remote cluster context.
getReplicationBacklog() - Method in interface org.apache.pulsar.common.policies.data.ReplicatorStats
Number of messages pending to be replicated to remote cluster.
getReplicationClusters(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
Get the replication clusters for a topic.
getReplicationClustersAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
Get the replication clusters for a topic asynchronously.
getReplicationConfigVersion(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the replication configuration version for a given namespace.
getReplicationConfigVersionAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the replication configuration version for a given namespace asynchronously.
getReplicationDelayInSeconds() - Method in interface org.apache.pulsar.common.policies.data.ReplicatorStats
Time in seconds from the time a message was produced to the time when it is about to be replicated.
getReplicatorDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get replicator-message-dispatch-rate.
getReplicatorDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get replicatorDispatchRate for the topic.
getReplicatorDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.Topics
getReplicatorDispatchRate(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get applied replicatorDispatchRate for the topic.
getReplicatorDispatchRate(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getReplicatorDispatchRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get replicator-message-dispatch-rate asynchronously.
getReplicatorDispatchRateAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get replicatorDispatchRate asynchronously.
getReplicatorDispatchRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
getReplicatorDispatchRateAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get applied replicatorDispatchRate asynchronously.
getReplicatorDispatchRateAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getResourceGroup(String) - Method in interface org.apache.pulsar.client.admin.ResourceGroups
Get configuration for a resourcegroup.
getResourceGroupAsync(String) - Method in interface org.apache.pulsar.client.admin.ResourceGroups
Get policies for a namespace asynchronously.
getResourceGroups() - Method in interface org.apache.pulsar.client.admin.ResourceGroups
Get the list of resourcegroups.
getResourceGroupsAsync() - Method in interface org.apache.pulsar.client.admin.ResourceGroups
Get the list of resourcegroups asynchronously.
getRetention(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the retention configuration for a namespace.
getRetention(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get the retention configuration for a topic.
getRetention(String) - Method in interface org.apache.pulsar.client.admin.Topics
Deprecated.
getRetention(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get the applied retention configuration for a topic.
getRetention(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getRetentionAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the retention configuration for a namespace asynchronously.
getRetentionAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get the retention configuration for a topic asynchronously.
getRetentionAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
Deprecated.
getRetentionAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get the applied retention configuration for a topic asynchronously.
getRetentionAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getRetentionSizeInMB() - Method in class org.apache.pulsar.common.policies.data.RetentionPolicies
 
getRetentionTimeInMinutes() - Method in class org.apache.pulsar.common.policies.data.RetentionPolicies
 
getRuntimeConfigurations() - Method in interface org.apache.pulsar.client.admin.Brokers
Get values of runtime configuration.
getRuntimeConfigurationsAsync() - Method in interface org.apache.pulsar.client.admin.Brokers
Get values of runtime configuration asynchronously.
getS3ManagedLedgerOffloadBucket() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
 
getS3ManagedLedgerOffloadCredentialId() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
 
getS3ManagedLedgerOffloadCredentialSecret() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
 
getS3ManagedLedgerOffloadMaxBlockSizeInBytes() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
 
getS3ManagedLedgerOffloadReadBufferSizeInBytes() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
 
getS3ManagedLedgerOffloadRegion() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
 
getS3ManagedLedgerOffloadRole() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
 
getS3ManagedLedgerOffloadRoleSessionName() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
 
getS3ManagedLedgerOffloadServiceEndpoint() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
 
getSchemaAutoUpdateCompatibilityStrategy(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Deprecated.
getSchemaCompatibilityStrategy(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the strategy used to check the a new schema provided by a producer is compatible with the current schema before it is installed.
getSchemaCompatibilityStrategy(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get schema compatibility strategy on a topic.
getSchemaCompatibilityStrategyAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the strategy used to check the a new schema provided by a producer is compatible with the current schema before it is installed asynchronously.
getSchemaCompatibilityStrategyAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get schema compatibility strategy on a topic asynchronously.
getSchemaInfo(String) - Method in interface org.apache.pulsar.client.admin.Schemas
Retrieve the latest schema of a topic.
getSchemaInfo(String, long) - Method in interface org.apache.pulsar.client.admin.Schemas
Retrieve the schema of a topic at a given version.
getSchemaInfoAsync(String) - Method in interface org.apache.pulsar.client.admin.Schemas
Retrieve the latest schema of a topic asynchronously.
getSchemaInfoAsync(String, long) - Method in interface org.apache.pulsar.client.admin.Schemas
Retrieve the schema of a topic at a given version asynchronously.
getSchemaInfoWithVersion(String) - Method in interface org.apache.pulsar.client.admin.Schemas
Retrieve the latest schema with verison of a topic.
getSchemaInfoWithVersionAsync(String) - Method in interface org.apache.pulsar.client.admin.Schemas
Retrieve the latest schema with verison of a topic asynchronously.
getSchemaValidationEnforced(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get schema validation enforced for namespace.
getSchemaValidationEnforced(String, boolean) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get schema validation enforced for namespace.
getSchemaValidationEnforced(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
Get schema validation enforced for a topic.
getSchemaValidationEnforcedAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get schema validation enforced for namespace asynchronously.
getSchemaValidationEnforcedAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get schema validation enforced for namespace asynchronously.
getSchemaValidationEnforcedAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
Get schema validation enforced for a topic asynchronously.
getSecondary() - Method in interface org.apache.pulsar.common.policies.data.NamespaceIsolationData
 
getServiceUrl() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
 
getServiceUrl() - Method in interface org.apache.pulsar.common.policies.data.BrokerInfo
 
getServiceUrl() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
 
getServiceUrlTls() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
 
getShadowSource(String) - Method in interface org.apache.pulsar.client.admin.Topics
Get the shadow source topic name of the given shadow topic.
getShadowSourceAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
Get the shadow source topic name of the given shadow topic asynchronously.
getShadowTopics(String) - Method in interface org.apache.pulsar.client.admin.Topics
Get shadow topic list of the source topic.
getShadowTopicsAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
Get shadow topic list of the source topic asynchronously.
getSink(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sinks
Get the configuration for the specified sink.
getSinkAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sinks
Get the configuration for the specified sink asynchronously.
getSinks() - Method in interface org.apache.pulsar.client.admin.Functions
Deprecated.
getSinkStatus(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sinks
Gets the current status of a sink.
getSinkStatus(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sinks
Gets the current status of a sink instance.
getSinkStatusAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sinks
Gets the current status of a sink asynchronously.
getSinkStatusAsync(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sinks
Gets the current status of a sink instance asynchronously.
getSlowTransactions(long, TimeUnit) - Method in interface org.apache.pulsar.client.admin.Transactions
Get slow transactions.
getSlowTransactionsAsync(long, TimeUnit) - Method in interface org.apache.pulsar.client.admin.Transactions
Get slow transactions.
getSlowTransactionsByCoordinatorId(Integer, long, TimeUnit) - Method in interface org.apache.pulsar.client.admin.Transactions
Get slow transactions by coordinator id.
getSlowTransactionsByCoordinatorIdAsync(Integer, long, TimeUnit) - Method in interface org.apache.pulsar.client.admin.Transactions
Get slow transactions by coordinator id.
getSource(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sources
Get the configuration for the specified source.
getSourceAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sources
Get the configuration for the specified source asynchronously.
getSources() - Method in interface org.apache.pulsar.client.admin.Functions
Deprecated.
getSourceStatus(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sources
Gets the current status of a source.
getSourceStatus(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sources
Gets the current status of a source instance.
getSourceStatusAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sources
Gets the current status of a source asynchronously.
getSourceStatusAsync(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sources
Gets the current status of a source instance asynchronously.
getStartTimestamp() - Method in interface org.apache.pulsar.policies.data.loadbalancer.ServiceLookupData
 
getStateStorageServiceUrl() - Method in class org.apache.pulsar.common.conf.InternalConfigurationData
 
getStats(String) - Method in interface org.apache.pulsar.client.admin.NonPersistentTopics
Deprecated.
Get the stats for the topic.
getStats(String) - Method in interface org.apache.pulsar.client.admin.Topics
 
getStats(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
 
getStats(String, boolean, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
 
getStats(String, boolean, boolean, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
 
getStats(String, GetStatsOptions) - Method in interface org.apache.pulsar.client.admin.Topics
Get the stats for the topic.
getStatsAsync(String) - Method in interface org.apache.pulsar.client.admin.NonPersistentTopics
Deprecated.
Get the stats for the topic asynchronously.
getStatsAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
 
getStatsAsync(String, boolean, boolean, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
Get the stats for the topic asynchronously.
GetStatsOptions - Class in org.apache.pulsar.client.admin
 
GetStatsOptions() - Constructor for class org.apache.pulsar.client.admin.GetStatsOptions
 
getStatus() - Method in interface org.apache.pulsar.client.admin.OffloadProcessStatus
 
getStatusCode() - Method in exception org.apache.pulsar.client.admin.PulsarAdminException
 
getStorageSize() - Method in interface org.apache.pulsar.common.policies.data.TopicStats
Space used to store the messages for the topic (bytes).
getSubscribeRate(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get namespace-subscribe-rate (topics under this namespace allow subscribe times per consumer in a period).
getSubscribeRate(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get topic-subscribe-rate (topics allow subscribe times per consumer in a period).
getSubscribeRate(String) - Method in interface org.apache.pulsar.client.admin.Topics
Deprecated.
getSubscribeRate(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get applied topic-subscribe-rate (topics allow subscribe times per consumer in a period).
getSubscribeRate(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getSubscribeRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get namespace-subscribe-rate asynchronously.
getSubscribeRateAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get topic-subscribe-rate asynchronously.
getSubscribeRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
getSubscribeRateAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get applied topic-subscribe-rate asynchronously.
getSubscribeRateAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getSubscriptionAuthentication() - Method in interface org.apache.pulsar.common.policies.data.AuthPolicies
 
getSubscriptionAuthMode(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the subscriptionAuthMode within a namespace.
getSubscriptionAuthModeAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the subscriptionAuthMode within a namespace asynchronously.
getSubscriptionDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get subscription-message-dispatch-rate.
getSubscriptionDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get subscription-message-dispatch-rate for the topic.
getSubscriptionDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.Topics
getSubscriptionDispatchRate(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get applied subscription-message-dispatch-rate.
getSubscriptionDispatchRate(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getSubscriptionDispatchRate(String, String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get subscription level dispatch rate limiter setting for a specific subscription.
getSubscriptionDispatchRate(String, String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
If applied is true, get dispatch rate limiter for a specific subscription.
getSubscriptionDispatchRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get subscription-message-dispatch-rate asynchronously.
getSubscriptionDispatchRateAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get subscription-message-dispatch-rate asynchronously.
getSubscriptionDispatchRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
getSubscriptionDispatchRateAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get applied subscription-message-dispatch-rate asynchronously.
getSubscriptionDispatchRateAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getSubscriptionDispatchRateAsync(String, String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
getSubscriptionDispatchRateAsync(String, String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
getSubscriptionExpirationTime(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the subscription expiration time for a namespace.
getSubscriptionExpirationTimeAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the subscription expiration time for a namespace asynchronously.
getSubscriptionProperties() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
SubscriptionProperties (key/value strings) associated with this subscribe.
getSubscriptionProperties(String, String) - Method in interface org.apache.pulsar.client.admin.Topics
Get Subscription Properties on a topic subscription.
getSubscriptionPropertiesAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Topics
Get Subscription Properties on a topic subscription.
getSubscriptions() - Method in interface org.apache.pulsar.common.policies.data.NonPersistentTopicStats
Map of subscriptions with their individual statistics.
getSubscriptions() - Method in interface org.apache.pulsar.common.policies.data.TopicStats
Map of subscriptions with their individual statistics.
getSubscriptions(String) - Method in interface org.apache.pulsar.client.admin.Topics
Get the list of subscriptions.
getSubscriptionsAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
Get the list of subscriptions asynchronously.
getSubscriptionTypesEnabled(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the subscriptionTypesEnabled policy for a given namespace, overriding broker settings.
getSubscriptionTypesEnabled(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get is enable sub types.
getSubscriptionTypesEnabled(String) - Method in interface org.apache.pulsar.client.admin.Topics
getSubscriptionTypesEnabledAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the subscriptionTypesEnabled policy for a given namespace, overriding broker settings.
getSubscriptionTypesEnabledAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Get is enable sub types asynchronously.
getSubscriptionTypesEnabledAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
getSystemExceptionsTotal() - Method in interface org.apache.pulsar.common.policies.data.FunctionInstanceStatsDataBase
 
getSystemExceptionsTotal() - Method in interface org.apache.pulsar.common.policies.data.FunctionStats
 
getTenantInfo(String) - Method in interface org.apache.pulsar.client.admin.Tenants
Get the config of the tenant.
getTenantInfoAsync(String) - Method in interface org.apache.pulsar.client.admin.Tenants
Get the config of the tenant asynchronously.
getTenants() - Method in interface org.apache.pulsar.client.admin.Tenants
Get the list of tenants.
getTenantsAsync() - Method in interface org.apache.pulsar.client.admin.Tenants
Get the list of tenants asynchronously.
getTickTime() - Method in interface org.apache.pulsar.common.policies.data.DelayedDeliveryPolicies
 
GettingAuthenticationDataException(String) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.GettingAuthenticationDataException
Deprecated.
GettingAuthenticationDataException(Throwable) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.GettingAuthenticationDataException
 
getTopicAuthentication() - Method in interface org.apache.pulsar.common.policies.data.AuthPolicies
 
getTopicEpoch() - Method in interface org.apache.pulsar.common.policies.data.TopicStats
The topic epoch or empty if not set.
getTopicHashPositions(String, String, List<String>) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get positions for topic list in a bundle.
getTopicHashPositionsAsync(String, String, List<String>) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get positions for topic list in a bundle.
getTopics() - Method in interface org.apache.pulsar.client.admin.BrokerStats
Returns JSON string topics stats.
getTopics() - Method in interface org.apache.pulsar.client.admin.ProxyStats
Returns Topics metrics.
getTopics(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the list of topics.
getTopics(String, ListNamespaceTopicsOptions) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the list of topics.
getTopicsAsync() - Method in interface org.apache.pulsar.client.admin.BrokerStats
Returns JSON string topics stats asynchronously.
getTopicsAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the list of topics asynchronously.
getTopicsAsync(String, ListNamespaceTopicsOptions) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the list of topics asynchronously.
getTopicType() - Method in interface org.apache.pulsar.common.policies.data.AutoTopicCreationOverride
 
getTotalMsgExpired() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
Total messages expired on this subscription.
getTransactionBufferInternalStats(String, boolean) - Method in interface org.apache.pulsar.client.admin.Transactions
Get transaction buffer internal stats.
getTransactionBufferInternalStatsAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Transactions
Get transaction buffer internal stats asynchronously.
getTransactionBufferStats(String) - Method in interface org.apache.pulsar.client.admin.Transactions
Get transaction buffer stats.
getTransactionBufferStats(String, boolean) - Method in interface org.apache.pulsar.client.admin.Transactions
Get transaction buffer stats.
getTransactionBufferStats(String, boolean, boolean) - Method in interface org.apache.pulsar.client.admin.Transactions
Get transaction buffer stats.
getTransactionBufferStatsAsync(String) - Method in interface org.apache.pulsar.client.admin.Transactions
Get transaction buffer stats.
getTransactionBufferStatsAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Transactions
Get transaction buffer stats.
getTransactionBufferStatsAsync(String, boolean, boolean) - Method in interface org.apache.pulsar.client.admin.Transactions
Get transaction buffer stats.
getTransactionInBufferStats(TxnID, String) - Method in interface org.apache.pulsar.client.admin.Transactions
Get transaction in buffer stats.
getTransactionInBufferStatsAsync(TxnID, String) - Method in interface org.apache.pulsar.client.admin.Transactions
Get transaction in buffer stats.
getTransactionInPendingAckStats(TxnID, String, String) - Method in interface org.apache.pulsar.client.admin.Transactions
Get transaction in pending ack stats.
getTransactionInPendingAckStatsAsync(TxnID, String, String) - Method in interface org.apache.pulsar.client.admin.Transactions
Get transaction in pending ack stats.
getTransactionMetadata(TxnID) - Method in interface org.apache.pulsar.client.admin.Transactions
Get transaction metadata.
getTransactionMetadataAsync(TxnID) - Method in interface org.apache.pulsar.client.admin.Transactions
Get transaction metadata.
getType() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
The subscription type as defined by SubscriptionType.
getUnackedMessages() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats
Number of unacknowledged messages for the consumer, where an unacknowledged message is one that has been sent to the consumer but not yet acknowledged.
getUnackedMessages() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
Number of unacknowledged messages for the subscription, where an unacknowledged message is one that has been sent to a consumer but not yet acknowledged.
getUserExceptionsTotal() - Method in interface org.apache.pulsar.common.policies.data.FunctionInstanceStatsDataBase
 
getUserExceptionsTotal() - Method in interface org.apache.pulsar.common.policies.data.FunctionStats
 
getUserMetrics() - Method in interface org.apache.pulsar.common.policies.data.FunctionInstanceStatsData
 
getValue() - Method in enum class org.apache.pulsar.client.admin.Mode
 
getValue() - Method in enum class org.apache.pulsar.common.policies.data.OffloadedReadPriority
 
getVersion() - Method in interface org.apache.pulsar.client.admin.Brokers
Get version of broker.
getVersionBySchema(String, PostSchemaPayload) - Method in interface org.apache.pulsar.client.admin.Schemas
Find schema version topic.
getVersionBySchema(String, SchemaInfo) - Method in interface org.apache.pulsar.client.admin.Schemas
Find schema version topic.
getVersionBySchemaAsync(String, PostSchemaPayload) - Method in interface org.apache.pulsar.client.admin.Schemas
Find schema version topic asynchronously.
getVersionBySchemaAsync(String, SchemaInfo) - Method in interface org.apache.pulsar.client.admin.Schemas
Find schema version topic asynchronously.
getWaitingPublishers() - Method in interface org.apache.pulsar.common.policies.data.TopicStats
 
getWebServiceUrl() - Method in interface org.apache.pulsar.policies.data.loadbalancer.ServiceLookupData
 
getWebServiceUrlTls() - Method in interface org.apache.pulsar.policies.data.loadbalancer.ServiceLookupData
 
getZookeeperServers() - Method in class org.apache.pulsar.common.conf.InternalConfigurationData
Deprecated.
GO - Enum constant in enum class org.apache.pulsar.common.functions.FunctionConfig.Runtime
 
grantPermission(String, String, Set<AuthAction>) - Method in interface org.apache.pulsar.client.admin.Topics
Grant permission on a topic.
grantPermissionAsync(String, String, Set<AuthAction>) - Method in interface org.apache.pulsar.client.admin.Topics
Grant permission on a topic asynchronously.
grantPermissionOnNamespace(String, String, Set<AuthAction>) - Method in interface org.apache.pulsar.client.admin.Namespaces
Grant permission on a namespace.
grantPermissionOnNamespaceAsync(String, String, Set<AuthAction>) - Method in interface org.apache.pulsar.client.admin.Namespaces
Grant permission on a namespace asynchronously.
grantPermissionOnSubscription(String, String, Set<String>) - Method in interface org.apache.pulsar.client.admin.Namespaces
Grant permission to role to access subscription's admin-api.
grantPermissionOnSubscriptionAsync(String, String, Set<String>) - Method in interface org.apache.pulsar.client.admin.Namespaces
Grant permission to role to access subscription's admin-api asynchronously.

H

hashCode() - Method in class org.apache.pulsar.common.conf.InternalConfigurationData
 
hashCode() - Method in class org.apache.pulsar.common.policies.data.PersistencePolicies
 
hashCode() - Method in class org.apache.pulsar.common.policies.data.Policies
 
hashCode() - Method in class org.apache.pulsar.common.policies.data.PublishRate
 
hashCode() - Method in class org.apache.pulsar.common.policies.data.RetentionPolicies
 
hashCode() - Method in class org.apache.pulsar.common.policies.data.SubscribeRate
 
hashCode() - Method in class org.apache.pulsar.common.stats.Metrics
 
healthcheck() - Method in interface org.apache.pulsar.client.admin.Brokers
Deprecated.
healthcheck(TopicVersion) - Method in interface org.apache.pulsar.client.admin.Brokers
Run a healthcheck on the broker.
healthcheckAsync() - Method in interface org.apache.pulsar.client.admin.Brokers
Deprecated.
healthcheckAsync(TopicVersion) - Method in interface org.apache.pulsar.client.admin.Brokers
Run a healthcheck on the broker asynchronously.
heapArenas - Variable in class org.apache.pulsar.common.stats.AllocatorStats
 
hostname(String) - Method in interface org.apache.pulsar.common.policies.data.BookieInfo.Builder
 
hostname(String) - Method in class org.apache.pulsar.common.policies.data.impl.BookieInfoImpl.BookieInfoImplBuilder
 
HOT - Enum constant in enum class org.apache.pulsar.common.policies.data.Policies.BundleType
 
HttpErrorException(Exception) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.HttpErrorException
 
HttpErrorException(Throwable) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.HttpErrorException
 

I

inactive_topic_policies - Variable in class org.apache.pulsar.common.policies.data.Policies
 
InactiveTopicDeleteMode - Enum Class in org.apache.pulsar.common.policies.data
Inactive topic deletion mode.
InactiveTopicPolicies - Class in org.apache.pulsar.common.policies.data
Definition of the inactive topic policy.
InactiveTopicPolicies() - Constructor for class org.apache.pulsar.common.policies.data.InactiveTopicPolicies
 
individuallyDeletedMessages - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.CursorStats
 
instanceId - Variable in class org.apache.pulsar.common.policies.data.FunctionStatus.FunctionInstanceStatus
 
instanceId - Variable in class org.apache.pulsar.common.policies.data.SinkStatus.SinkInstanceStatus
 
instanceId - Variable in class org.apache.pulsar.common.policies.data.SourceStatus.SourceInstanceStatus
 
instances - Variable in class org.apache.pulsar.common.policies.data.FunctionStatus
 
instances - Variable in class org.apache.pulsar.common.policies.data.SinkStatus
 
instances - Variable in class org.apache.pulsar.common.policies.data.SourceStatus
 
InternalConfigurationData - Class in org.apache.pulsar.common.conf
Internal configuration data.
InternalConfigurationData() - Constructor for class org.apache.pulsar.common.conf.InternalConfigurationData
 
InternalConfigurationData(String, String, String, String, String) - Constructor for class org.apache.pulsar.common.conf.InternalConfigurationData
 
InvalidPosition - Enum constant in enum class org.apache.pulsar.common.stats.PositionInPendingAckStats.State
 
is_active - Variable in class org.apache.pulsar.common.policies.data.NamespaceOwnershipStatus
 
is_allow_auto_update_schema - Variable in class org.apache.pulsar.common.policies.data.Policies
 
is_controlled - Variable in class org.apache.pulsar.common.policies.data.NamespaceOwnershipStatus
 
isActive() - Method in interface org.apache.pulsar.common.policies.data.BrokerStatus
 
isActive() - Method in interface org.apache.pulsar.common.policies.data.DelayedDeliveryPolicies
 
isAllowAutoSubscriptionCreation() - Method in interface org.apache.pulsar.common.policies.data.AutoSubscriptionCreationOverride
 
isAllowAutoTopicCreation() - Method in interface org.apache.pulsar.common.policies.data.AutoTopicCreationOverride
 
isAllowOutOfOrderDelivery() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
Whether out of order delivery is allowed on the Key_Shared subscription.
isBlockedConsumerOnUnackedMsgs() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats
Flag to verify if consumer is blocked due to reaching threshold of unacked messages.
isBlockedSubscriptionOnUnackedMsgs() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
Flag to verify if subscription is blocked due to reaching threshold of unacked messages.
isBrokerAvailable(BrokerStatus) - Method in class org.apache.pulsar.common.policies.AutoFailoverPolicy
Determine whether a broker is considered available or not.
isBrokerAvailable(BrokerStatus) - Method in class org.apache.pulsar.common.policies.impl.MinAvailablePolicy
 
isBrokerClientTlsEnabled() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
 
isBrokerClientTlsEnabledWithKeyStore() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
 
IsCompatibilityResponse - Class in org.apache.pulsar.common.protocol.schema
Response defining if a schema is compatible with existing topic's schema.
IsCompatibilityResponse() - Constructor for class org.apache.pulsar.common.protocol.schema.IsCompatibilityResponse
 
isConnected() - Method in interface org.apache.pulsar.common.policies.data.ReplicatorStats
is the replication-subscriber up and running to replicate to remote cluster.
isDurable() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
Tells whether this subscription is durable or ephemeral (eg.: from a reader).
isEmpty() - Method in class org.apache.pulsar.common.policies.data.ClusterData.ClusterUrl
 
isMigrated() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
 
isMsgChunkPublished() - Method in interface org.apache.pulsar.common.policies.data.TopicStats
Topic has chunked message published on it.
isNonPersistentTopicsEnabled() - Method in interface org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport
 
isPersistentTopicsEnabled() - Method in interface org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport
 
isPrimary() - Method in interface org.apache.pulsar.common.policies.data.BrokerNamespaceIsolationData
 
isRelativeToPublishRate() - Method in interface org.apache.pulsar.common.policies.data.DispatchRate
 
isReplicated() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats
Mark that the subscription state is kept in sync across different regions.
isSupportsPartialProducer() - Method in interface org.apache.pulsar.common.policies.data.PublisherStats
Whether partial producer is supported at client.
isTlsAllowInsecureConnection() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
 
isUndefined(SchemaCompatibilityStrategy) - Static method in enum class org.apache.pulsar.common.policies.data.SchemaCompatibilityStrategy
 
isUpdateAuthData() - Method in interface org.apache.pulsar.common.functions.UpdateOptions
 
isValidTopicType(String) - Static method in enum class org.apache.pulsar.common.policies.data.TopicType
 

J

JAVA - Enum constant in enum class org.apache.pulsar.common.functions.FunctionConfig.Runtime
 

L

LARGEST - Enum constant in enum class org.apache.pulsar.common.policies.data.Policies.BundleType
 
LAST_BOUNDARY - Static variable in class org.apache.pulsar.common.policies.data.Policies
 
lastConfirmedEntry - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats
The ledgerid: entryid of the last message that is written successfully.
lastError - Variable in class org.apache.pulsar.client.admin.LongRunningProcessStatus
 
lastInvocationTime - Variable in class org.apache.pulsar.common.policies.data.FunctionStatus.FunctionInstanceStatus.FunctionInstanceStatusData
 
lastLedgerCreatedTimestamp - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats
The time when the last ledger is created.
lastLedgerCreationFailureTimestamp - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats
The time when the last ledger failed.
lastLedgerSwitchTimestamp - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.CursorStats
 
lastReceivedTime - Variable in class org.apache.pulsar.common.policies.data.SinkStatus.SinkInstanceStatus.SinkInstanceStatusData
 
lastReceivedTime - Variable in class org.apache.pulsar.common.policies.data.SourceStatus.SourceInstanceStatus.SourceInstanceStatusData
 
lastSnapshotTimestamps - Variable in class org.apache.pulsar.common.policies.data.TransactionBufferStats
The last snapshot timestamps of this transaction buffer.
lastTookSnapshotSegmentTimestamp - Variable in class org.apache.pulsar.common.policies.data.SegmentsStats
The last snapshot segment timestamps of this transaction buffer.
lastTxnID - Variable in class org.apache.pulsar.common.policies.data.SegmentStats
 
latency_stats_sample_rate - Variable in class org.apache.pulsar.common.policies.data.Policies
 
latestSinkExceptions - Variable in class org.apache.pulsar.common.policies.data.SinkStatus.SinkInstanceStatus.SinkInstanceStatusData
 
latestSourceExceptions - Variable in class org.apache.pulsar.common.policies.data.SourceStatus.SourceInstanceStatus.SourceInstanceStatusData
 
latestSystemExceptions - Variable in class org.apache.pulsar.common.policies.data.FunctionStatus.FunctionInstanceStatus.FunctionInstanceStatusData
 
latestSystemExceptions - Variable in class org.apache.pulsar.common.policies.data.SinkStatus.SinkInstanceStatus.SinkInstanceStatusData
 
latestSystemExceptions - Variable in class org.apache.pulsar.common.policies.data.SourceStatus.SourceInstanceStatus.SourceInstanceStatusData
 
latestUserExceptions - Variable in class org.apache.pulsar.common.policies.data.FunctionStatus.FunctionInstanceStatus.FunctionInstanceStatusData
 
leastSigBits - Variable in class org.apache.pulsar.common.policies.data.TransactionCoordinatorStats
The sequenceId of transaction metadataStore.
leastSigBits - Variable in class org.apache.pulsar.common.policies.data.TransactionCoordinatorStatus
The sequenceId of transaction metadataStore.
ledgerId - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.LedgerInfo
 
LedgerInfo() - Constructor for class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.LedgerInfo
 
ledgers - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats
The ordered list of all ledgers for this topic holding messages.
limit - Variable in class org.apache.pulsar.policies.data.loadbalancer.ResourceUsage
 
limitSize(long) - Method in interface org.apache.pulsar.common.policies.data.BacklogQuota.Builder
 
limitSize(long) - Method in class org.apache.pulsar.common.policies.data.impl.BacklogQuotaImpl.BacklogQuotaImplBuilder
 
limitTime(int) - Method in interface org.apache.pulsar.common.policies.data.BacklogQuota.Builder
 
limitTime(int) - Method in class org.apache.pulsar.common.policies.data.impl.BacklogQuotaImpl.BacklogQuotaImplBuilder
 
listenerName(String) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
 
ListNamespaceTopicsOptions - Class in org.apache.pulsar.client.admin
 
ListNamespaceTopicsOptions() - Constructor for class org.apache.pulsar.client.admin.ListNamespaceTopicsOptions
 
listPackages(String, String) - Method in interface org.apache.pulsar.client.admin.Packages
List all the packages with the given type in a namespace.
listPackagesAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Packages
List all the packages with the given type in a namespace asynchronously.
listPackageVersions(String) - Method in interface org.apache.pulsar.client.admin.Packages
List all the versions of a package.
listPackageVersionsAsync(String) - Method in interface org.apache.pulsar.client.admin.Packages
List all the versions of a package asynchronously.
listSinks(String, String) - Method in interface org.apache.pulsar.client.admin.Sinks
Get the list of sinks.
listSinksAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Sinks
Get the list of sinks asynchronously.
listSources(String, String) - Method in interface org.apache.pulsar.client.admin.Sources
Get the list of sources.
listSourcesAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Sources
Get the list of sources asynchronously.
ListTopicsOptions - Class in org.apache.pulsar.client.admin
 
ListTopicsOptions() - Constructor for class org.apache.pulsar.client.admin.ListTopicsOptions
 
listTransactionCoordinators() - Method in interface org.apache.pulsar.client.admin.Transactions
List transaction coordinators.
listTransactionCoordinatorsAsync() - Method in interface org.apache.pulsar.client.admin.Transactions
List transaction coordinators.
loadConf(Map<String, Object>) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder
Load the configuration from provided config map.
loadFactor(int) - Method in interface org.apache.pulsar.common.policies.data.BrokerStatus.Builder
 
loadFactor(int) - Method in class org.apache.pulsar.common.policies.data.impl.BrokerStatusImpl.BrokerStatusImplBuilder
 
LoadManagerReport - Interface in org.apache.pulsar.policies.data.loadbalancer
This class represents the overall load of the broker - it includes overall SystemResourceUsage and Bundle-usage.
LongRunningProcessStatus - Class in org.apache.pulsar.client.admin
Status of long running process.
LongRunningProcessStatus() - Constructor for class org.apache.pulsar.client.admin.LongRunningProcessStatus
 
LongRunningProcessStatus.Status - Enum Class in org.apache.pulsar.client.admin
Status code.
Lookup - Interface in org.apache.pulsar.client.admin
This is an interface class to allow using command line tool to quickly lookup the broker serving the topic.
lookupPartitionedTopic(String) - Method in interface org.apache.pulsar.client.admin.Lookup
Lookup a partitioned topic.
lookupPartitionedTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.Lookup
Lookup a partitioned topic.
lookups() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
 
lookupTopic(String) - Method in interface org.apache.pulsar.client.admin.Lookup
Lookup a topic.
lookupTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.Lookup
Lookup a topic asynchronously.
lowWaterMark - Variable in class org.apache.pulsar.common.policies.data.TransactionCoordinatorStats
The low water mark of transaction metadataStore.
lowWaterMark - Variable in class org.apache.pulsar.common.policies.data.TransactionCoordinatorStatus
The low water mark of transaction metadataStore.
lowWaterMarks - Variable in class org.apache.pulsar.common.policies.data.TransactionBufferStats
(Optional) The lowWaterMark details of the transaction buffer.
lowWaterMarks - Variable in class org.apache.pulsar.common.policies.data.TransactionPendingAckStats
(Optional) The lowWaterMark details of the transaction pending ack.

M

managedLedgerInternalStats - Variable in class org.apache.pulsar.common.policies.data.SnapshotSystemTopicInternalStats
 
managedLedgerInternalStats - Variable in class org.apache.pulsar.common.policies.data.TransactionLogStats
The manage ledger internal stats.
ManagedLedgerInternalStats - Class in org.apache.pulsar.common.policies.data
ManagedLedger internal statistics.
ManagedLedgerInternalStats() - Constructor for class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats
 
ManagedLedgerInternalStats.CursorStats - Class in org.apache.pulsar.common.policies.data
Pulsar cursor statistics.
ManagedLedgerInternalStats.LedgerInfo - Class in org.apache.pulsar.common.policies.data
Ledger information.
managedLedgerName - Variable in class org.apache.pulsar.common.policies.data.SnapshotSystemTopicInternalStats
 
managedLedgerName - Variable in class org.apache.pulsar.common.policies.data.TransactionLogStats
The managed ledger name.
managedLedgerOffloadBucket(String) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
 
managedLedgerOffloadDeletionLagInMillis(Long) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
 
managedLedgerOffloadDriver(String) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
 
managedLedgerOffloadedReadPriority(OffloadedReadPriority) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
 
managedLedgerOffloadMaxBlockSizeInBytes(Integer) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
 
managedLedgerOffloadMaxThreads(Integer) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
 
managedLedgerOffloadPrefetchRounds(Integer) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
 
managedLedgerOffloadReadBufferSizeInBytes(Integer) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
 
managedLedgerOffloadRegion(String) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
 
managedLedgerOffloadServiceEndpoint(String) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
 
managedLedgerOffloadThresholdInBytes(Long) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
 
managedLedgerOffloadThresholdInSeconds(Long) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
 
MANUAL - Enum constant in enum class org.apache.pulsar.common.functions.FunctionConfig.ProcessingGuarantees
 
MarkDelete - Enum constant in enum class org.apache.pulsar.common.stats.PositionInPendingAckStats.State
 
markDeletePosition - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.CursorStats
 
max_consumers_per_subscription - Variable in class org.apache.pulsar.common.policies.data.Policies
 
max_consumers_per_topic - Variable in class org.apache.pulsar.common.policies.data.Policies
 
max_producers_per_topic - Variable in class org.apache.pulsar.common.policies.data.Policies
 
max_subscriptions_per_topic - Variable in class org.apache.pulsar.common.policies.data.Policies
 
max_topics_per_namespace - Variable in class org.apache.pulsar.common.policies.data.Policies
 
max_unacked_messages_per_consumer - Variable in class org.apache.pulsar.common.policies.data.Policies
 
max_unacked_messages_per_subscription - Variable in class org.apache.pulsar.common.policies.data.Policies
 
maxNumElements - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolSubpageStats
 
maxReadPosition - Variable in class org.apache.pulsar.common.policies.data.TransactionBufferStats
The max read position of this transaction buffer.
maxUsage - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolChunkListStats
 
MEDIA_TYPE - Static variable in class org.apache.pulsar.common.partition.PartitionedTopicMetadata
 
mergeWithDefault(Resources) - Static method in class org.apache.pulsar.common.functions.Resources
 
message_age - Enum constant in enum class org.apache.pulsar.common.policies.data.BacklogQuota.BacklogQuotaType
 
message_ttl_in_seconds - Variable in class org.apache.pulsar.common.policies.data.Policies
 
messagesConsumedCounter - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.CursorStats
 
metadata - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.LedgerInfo
 
metadata - Variable in class org.apache.pulsar.common.policies.data.PartitionedTopicInternalStats
 
MetadataFormatException(String) - Constructor for exception org.apache.pulsar.packages.management.core.exceptions.PackagesManagementException.MetadataFormatException
Constructs an MetadataFormatException with the specified detail message.
MetadataFormatException(String, Throwable) - Constructor for exception org.apache.pulsar.packages.management.core.exceptions.PackagesManagementException.MetadataFormatException
Constructs an MetadataFormatException with the specified detail message and the cause.
metrics - Variable in class org.apache.pulsar.common.policies.data.WorkerFunctionInstanceStats
 
Metrics - Class in org.apache.pulsar.common.stats
WARNING : do not add any getters as the Jackson parser will output that getter.
Metrics() - Constructor for class org.apache.pulsar.common.stats.Metrics
 
Metrics(Map<String, String>) - Constructor for class org.apache.pulsar.common.stats.Metrics
 
migrated(boolean) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
 
migratedClusterUrl(ClusterData.ClusterUrl) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
 
min_available - Enum constant in enum class org.apache.pulsar.common.policies.data.AutoFailoverPolicyType
 
min_limit - Variable in class org.apache.pulsar.common.policies.impl.MinAvailablePolicy
 
MinAvailablePolicy - Class in org.apache.pulsar.common.policies.impl
Implementation of min available policy.
MinAvailablePolicy(AutoFailoverPolicyData) - Constructor for class org.apache.pulsar.common.policies.impl.MinAvailablePolicy
 
minUsage - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolChunkListStats
 
Mode - Enum Class in org.apache.pulsar.client.admin
 
msgRateIn - Variable in class org.apache.pulsar.policies.data.loadbalancer.NamespaceBundleStats
 
msgRateOut - Variable in class org.apache.pulsar.policies.data.loadbalancer.NamespaceBundleStats
 
msgThroughputIn - Variable in class org.apache.pulsar.policies.data.loadbalancer.NamespaceBundleStats
 
msgThroughputOut - Variable in class org.apache.pulsar.policies.data.loadbalancer.NamespaceBundleStats
 

N

name - Variable in class org.apache.pulsar.common.policies.data.WorkerFunctionInstanceStats
Fully qualified function instance name.
namespaceAuthentication(Map<String, Set<AuthAction>>) - Method in interface org.apache.pulsar.common.policies.data.AuthPolicies.Builder
 
NamespaceBundleStats - Class in org.apache.pulsar.policies.data.loadbalancer
 
NamespaceBundleStats() - Constructor for class org.apache.pulsar.policies.data.loadbalancer.NamespaceBundleStats
 
NamespaceIsolationData - Interface in org.apache.pulsar.common.policies.data
 
NamespaceIsolationData.Builder - Interface in org.apache.pulsar.common.policies.data
 
NamespaceOwnershipStatus - Class in org.apache.pulsar.common.policies.data
Information about the namespace's ownership.
NamespaceOwnershipStatus() - Constructor for class org.apache.pulsar.common.policies.data.NamespaceOwnershipStatus
 
NamespaceOwnershipStatus(BrokerAssignment, boolean, boolean) - Constructor for class org.apache.pulsar.common.policies.data.NamespaceOwnershipStatus
 
namespaceRegex(List<String>) - Method in interface org.apache.pulsar.common.policies.data.BrokerNamespaceIsolationData.Builder
 
namespaces() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
 
namespaces(List<String>) - Method in interface org.apache.pulsar.common.policies.data.NamespaceIsolationData.Builder
 
Namespaces - Interface in org.apache.pulsar.client.admin
Admin interface for namespaces management.
newAdminClientBuilder() - Static method in class org.apache.pulsar.client.admin.utils.DefaultImplementation
 
newBuilder(String) - Static method in class org.apache.pulsar.client.admin.utils.ReflectionUtils
 
newOffloadProcessStatus(LongRunningProcessStatus.Status, String, MessageId) - Static method in class org.apache.pulsar.client.admin.utils.DefaultImplementation
 
NON_PARTITIONED - Enum constant in enum class org.apache.pulsar.common.policies.data.TopicType
 
NON_PARTITIONED - Static variable in class org.apache.pulsar.common.partition.PartitionedTopicMetadata
A topic with '0' partitions is treated like non-partitioned topic.
non_persistent - Enum constant in enum class org.apache.pulsar.common.naming.TopicDomain
 
NON_PERSISTENT - Enum constant in enum class org.apache.pulsar.client.admin.Mode
 
None - Enum constant in enum class org.apache.pulsar.common.policies.data.SubscriptionAuthMode
Every subscription name can be used by every role.
NonPersistentPartitionedTopicStats - Interface in org.apache.pulsar.common.policies.data
Statistics for a non-persistent partitioned topic.
NonPersistentPublisherStats - Interface in org.apache.pulsar.common.policies.data
Non-persistent publisher statistics.
NonPersistentReplicatorStats - Interface in org.apache.pulsar.common.policies.data
Statistics for a non-persistent replicator.
NonPersistentSubscriptionStats - Interface in org.apache.pulsar.common.policies.data
Statistics for subscription to non-persistent topics.
nonPersistentTopics() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
Deprecated.
Since 2.0. See PulsarAdmin.topics()
NonPersistentTopics - Interface in org.apache.pulsar.client.admin
Deprecated.
since 2.0. See Topics
NonPersistentTopicStats - Interface in org.apache.pulsar.common.policies.data
Statistics for a non-persistent topic.
normalCacheSize - Variable in class org.apache.pulsar.common.stats.AllocatorStats
 
normalize(DispatchRateImpl) - Static method in class org.apache.pulsar.common.policies.data.impl.DispatchRateImpl
 
normalize(PublishRate) - Static method in class org.apache.pulsar.common.policies.data.PublishRate
 
normalize(SubscribeRate) - Static method in class org.apache.pulsar.common.policies.data.SubscribeRate
 
NOT_RUN - Enum constant in enum class org.apache.pulsar.client.admin.LongRunningProcessStatus.Status
 
NotAllowedException(Throwable, String, int) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.NotAllowedException
 
NotAuthorizedException(Throwable, String, int) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.NotAuthorizedException
 
NotFoundException(String) - Constructor for exception org.apache.pulsar.packages.management.core.exceptions.PackagesManagementException.NotFoundException
Constructs an NotFoundException with the specified detail message.
NotFoundException(String, Throwable) - Constructor for exception org.apache.pulsar.packages.management.core.exceptions.PackagesManagementException.NotFoundException
Constructs an NotFoundException with the specified detail message and the cause.
NotFoundException(Throwable) - Constructor for exception org.apache.pulsar.packages.management.core.exceptions.PackagesManagementException.NotFoundException
Constructs an NotFoundException with the specified cause.
NotFoundException(Throwable, String, int) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.NotFoundException
 
NotInPendingAck - Enum constant in enum class org.apache.pulsar.common.stats.PositionInPendingAckStats.State
 
numActiveAllocations - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolArenaStats
 
numActiveHugeAllocations - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolArenaStats
 
numActiveNormalAllocations - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolArenaStats
 
numActiveSmallAllocations - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolArenaStats
 
numAllocations - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolArenaStats
 
numAvailable - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolSubpageStats
 
numberOfEntries - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats
The total number of entries being tracked.
numberOfEntriesSinceFirstNotAckedMessage - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.CursorStats
 
numBundles(int) - Method in interface org.apache.pulsar.common.policies.data.BundlesData.Builder
 
numBundles(int) - Method in class org.apache.pulsar.common.policies.data.impl.BundlesDataImpl.BundlesDataImplBuilder
 
numChunkLists - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolArenaStats
 
numDeallocations - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolArenaStats
 
numDirectArenas - Variable in class org.apache.pulsar.common.stats.AllocatorStats
 
numHeapArenas - Variable in class org.apache.pulsar.common.stats.AllocatorStats
 
numHugeAllocations - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolArenaStats
 
numHugeDeallocations - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolArenaStats
 
numInstances - Variable in class org.apache.pulsar.common.policies.data.FunctionStatus
 
numInstances - Variable in class org.apache.pulsar.common.policies.data.SinkStatus
 
numInstances - Variable in class org.apache.pulsar.common.policies.data.SourceStatus
 
numNormalAllocations - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolArenaStats
 
numNormalDeallocations - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolArenaStats
 
numReadFromPulsar - Variable in class org.apache.pulsar.common.policies.data.SinkStatus.SinkInstanceStatus.SinkInstanceStatusData
 
numReceived - Variable in class org.apache.pulsar.common.policies.data.FunctionStatus.FunctionInstanceStatus.FunctionInstanceStatusData
 
numReceivedFromSource - Variable in class org.apache.pulsar.common.policies.data.SourceStatus.SourceInstanceStatus.SourceInstanceStatusData
 
numRestarts - Variable in class org.apache.pulsar.common.policies.data.FunctionStatus.FunctionInstanceStatus.FunctionInstanceStatusData
 
numRestarts - Variable in class org.apache.pulsar.common.policies.data.SinkStatus.SinkInstanceStatus.SinkInstanceStatusData
 
numRestarts - Variable in class org.apache.pulsar.common.policies.data.SourceStatus.SourceInstanceStatus.SourceInstanceStatusData
 
numRunning - Variable in class org.apache.pulsar.common.policies.data.FunctionStatus
 
numRunning - Variable in class org.apache.pulsar.common.policies.data.SinkStatus
 
numRunning - Variable in class org.apache.pulsar.common.policies.data.SourceStatus
 
numSinkExceptions - Variable in class org.apache.pulsar.common.policies.data.SinkStatus.SinkInstanceStatus.SinkInstanceStatusData
 
numSmallAllocations - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolArenaStats
 
numSmallDeallocations - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolArenaStats
 
numSmallSubpages - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolArenaStats
 
numSourceExceptions - Variable in class org.apache.pulsar.common.policies.data.SourceStatus.SourceInstanceStatus.SourceInstanceStatusData
 
numSuccessfullyProcessed - Variable in class org.apache.pulsar.common.policies.data.FunctionStatus.FunctionInstanceStatus.FunctionInstanceStatusData
 
numSystemExceptions - Variable in class org.apache.pulsar.common.policies.data.FunctionStatus.FunctionInstanceStatus.FunctionInstanceStatusData
 
numSystemExceptions - Variable in class org.apache.pulsar.common.policies.data.SinkStatus.SinkInstanceStatus.SinkInstanceStatusData
 
numSystemExceptions - Variable in class org.apache.pulsar.common.policies.data.SourceStatus.SourceInstanceStatus.SourceInstanceStatusData
 
numThreadLocalCaches - Variable in class org.apache.pulsar.common.stats.AllocatorStats
 
numUserExceptions - Variable in class org.apache.pulsar.common.policies.data.FunctionStatus.FunctionInstanceStatus.FunctionInstanceStatusData
 
numWritten - Variable in class org.apache.pulsar.common.policies.data.SourceStatus.SourceInstanceStatus.SourceInstanceStatusData
 
numWrittenToSink - Variable in class org.apache.pulsar.common.policies.data.SinkStatus.SinkInstanceStatus.SinkInstanceStatusData
 

O

of(String, String, int) - Static method in class org.apache.pulsar.common.functions.WorkerInfo
 
offload_deletion_lag_ms - Variable in class org.apache.pulsar.common.policies.data.Policies
 
offload_policies - Variable in class org.apache.pulsar.common.policies.data.Policies
 
offload_threshold - Variable in class org.apache.pulsar.common.policies.data.Policies
 
offload_threshold_in_seconds - Variable in class org.apache.pulsar.common.policies.data.Policies
 
offloaded - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.LedgerInfo
 
OffloadedReadPriority - Enum Class in org.apache.pulsar.common.policies.data
 
offloadersDirectory(String) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
 
OffloadPolicies - Interface in org.apache.pulsar.common.policies.data
 
OffloadPolicies.Builder - Interface in org.apache.pulsar.common.policies.data
 
OffloadProcessStatus - Interface in org.apache.pulsar.client.admin
interface class of Status of offload process.
offloadStatus(String) - Method in interface org.apache.pulsar.client.admin.Topics
Check the status of an ongoing offloading operation for a topic.
offloadStatusAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
Check the status of an ongoing offloading operation for a topic asynchronously.
ongoingTxnSize - Variable in class org.apache.pulsar.common.policies.data.TransactionBufferStats
The total number of ongoing transactions in this transaction buffer.
ongoingTxnSize - Variable in class org.apache.pulsar.common.policies.data.TransactionCoordinatorStats
The total number of ongoing transactions in this transaction coordinator.
ongoingTxnSize - Variable in class org.apache.pulsar.common.policies.data.TransactionPendingAckStats
The total number of ongoing transactions in this transaction pending ack.
openTimestamp - Variable in class org.apache.pulsar.common.policies.data.TransactionMetadata
The open time of this transaction.
org.apache.pulsar.client.admin - package org.apache.pulsar.client.admin
 
org.apache.pulsar.client.admin.utils - package org.apache.pulsar.client.admin.utils
Helpers which provide useful functionality for the implementation of Pulsar Client API.
org.apache.pulsar.common.conf - package org.apache.pulsar.common.conf
Classes for internal configuration.
org.apache.pulsar.common.functions - package org.apache.pulsar.common.functions
Implementation of policies.
org.apache.pulsar.common.io - package org.apache.pulsar.common.io
Implementation of policies.
org.apache.pulsar.common.naming - package org.apache.pulsar.common.naming
Implementation of policies.
org.apache.pulsar.common.partition - package org.apache.pulsar.common.partition
Implementation of policies.
org.apache.pulsar.common.policies - package org.apache.pulsar.common.policies
Implementation of policies.
org.apache.pulsar.common.policies.data - package org.apache.pulsar.common.policies.data
Implementation of policies.
org.apache.pulsar.common.policies.data.impl - package org.apache.pulsar.common.policies.data.impl
 
org.apache.pulsar.common.policies.impl - package org.apache.pulsar.common.policies.impl
Implementation of policies.
org.apache.pulsar.common.protocol.schema - package org.apache.pulsar.common.protocol.schema
Implementation of policies.
org.apache.pulsar.common.stats - package org.apache.pulsar.common.stats
Implementation of policies.
org.apache.pulsar.packages.management.core.common - package org.apache.pulsar.packages.management.core.common
Packages management general classes.
org.apache.pulsar.packages.management.core.exceptions - package org.apache.pulsar.packages.management.core.exceptions
Exceptions of the packages management service thrown.
org.apache.pulsar.policies.data.loadbalancer - package org.apache.pulsar.policies.data.loadbalancer
Implementation of policies.
owner - Variable in class org.apache.pulsar.common.policies.data.TransactionMetadata
The owner of this transaction.

P

PackageMetadata - Class in org.apache.pulsar.packages.management.core.common
Package metadata.
PackageMetadata() - Constructor for class org.apache.pulsar.packages.management.core.common.PackageMetadata
 
packages - Enum constant in enum class org.apache.pulsar.common.policies.data.AuthAction
Permissions for packages ops.
packages() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
 
Packages - Interface in org.apache.pulsar.client.admin
Administration operations of the packages management service.
PackagesManagementException - Exception in org.apache.pulsar.packages.management.core.exceptions
Packages management related exceptions.
PackagesManagementException(String) - Constructor for exception org.apache.pulsar.packages.management.core.exceptions.PackagesManagementException
Constructs an PackagesManagementException with the specified detail message.
PackagesManagementException(String, Throwable) - Constructor for exception org.apache.pulsar.packages.management.core.exceptions.PackagesManagementException
Constructs an PackagesManagementException with the specified detail message and the cause.
PackagesManagementException(Throwable) - Constructor for exception org.apache.pulsar.packages.management.core.exceptions.PackagesManagementException
Constructs an PackagesManagementException with the specified cause.
PackagesManagementException.MetadataFormatException - Exception in org.apache.pulsar.packages.management.core.exceptions
 
PackagesManagementException.NotFoundException - Exception in org.apache.pulsar.packages.management.core.exceptions
 
PackageType - Enum Class in org.apache.pulsar.packages.management.core.common
PackageType used to identify the package type.
pageSize - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolSubpageStats
 
parameters(Map<String, String>) - Method in interface org.apache.pulsar.common.policies.data.AutoFailoverPolicyData.Builder
 
parseFrom(String) - Static method in class org.apache.pulsar.common.functions.WorkerInfo
 
PARTITIONED - Enum constant in enum class org.apache.pulsar.common.policies.data.TopicType
 
PartitionedTopicInternalStats - Class in org.apache.pulsar.common.policies.data
Internal statistics for a partitioned topic.
PartitionedTopicInternalStats() - Constructor for class org.apache.pulsar.common.policies.data.PartitionedTopicInternalStats
 
PartitionedTopicInternalStats(PartitionedTopicMetadata) - Constructor for class org.apache.pulsar.common.policies.data.PartitionedTopicInternalStats
 
PartitionedTopicMetadata - Class in org.apache.pulsar.common.partition
Metadata of a partitioned topic.
PartitionedTopicMetadata() - Constructor for class org.apache.pulsar.common.partition.PartitionedTopicMetadata
 
PartitionedTopicMetadata(int) - Constructor for class org.apache.pulsar.common.partition.PartitionedTopicMetadata
 
PartitionedTopicMetadata(int, Map<String, String>) - Constructor for class org.apache.pulsar.common.partition.PartitionedTopicMetadata
 
PartitionedTopicStats - Interface in org.apache.pulsar.common.policies.data
Statistics for a partitioned topic.
partitions - Variable in class org.apache.pulsar.common.partition.PartitionedTopicMetadata
 
partitions - Variable in class org.apache.pulsar.common.policies.data.PartitionedTopicInternalStats
 
peekMessages(String, String, int) - Method in interface org.apache.pulsar.client.admin.Topics
Peek messages from a topic subscription.
peekMessagesAsync(String, String, int) - Method in interface org.apache.pulsar.client.admin.Topics
Peek messages from a topic subscription asynchronously.
peerClusterNames(LinkedHashSet<String>) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
 
PendingAck - Enum constant in enum class org.apache.pulsar.common.stats.PositionInPendingAckStats.State
 
pendingAckLogStats - Variable in class org.apache.pulsar.common.policies.data.TransactionPendingAckInternalStats
The transaction pending ack log stats.
PendingAckNotReady - Enum constant in enum class org.apache.pulsar.common.stats.PositionInPendingAckStats.State
 
pendingAddEntriesCount - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats
The number of messages that complete (asynchronous) write requests.
pendingReadOps - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.CursorStats
 
percentUsage() - Method in class org.apache.pulsar.policies.data.loadbalancer.ResourceUsage
 
persistence - Variable in class org.apache.pulsar.common.policies.data.Policies
 
PersistencePolicies - Class in org.apache.pulsar.common.policies.data
Configuration of bookkeeper persistence policies.
PersistencePolicies() - Constructor for class org.apache.pulsar.common.policies.data.PersistencePolicies
 
PersistencePolicies(int, int, int, double) - Constructor for class org.apache.pulsar.common.policies.data.PersistencePolicies
 
persistent - Enum constant in enum class org.apache.pulsar.common.naming.TopicDomain
 
PERSISTENT - Enum constant in enum class org.apache.pulsar.client.admin.Mode
 
persistentPosition - Variable in class org.apache.pulsar.common.policies.data.SegmentStats
 
PersistentTopicInternalStats - Class in org.apache.pulsar.common.policies.data
Persistent topic internal statistics.
PersistentTopicInternalStats() - Constructor for class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats
 
Policies - Class in org.apache.pulsar.common.policies.data
Definition of Pulsar policies.
Policies() - Constructor for class org.apache.pulsar.common.policies.data.Policies
 
Policies.BundleType - Enum Class in org.apache.pulsar.common.policies.data
 
policyName(String) - Method in interface org.apache.pulsar.common.policies.data.BrokerNamespaceIsolationData.Builder
 
policyType(AutoFailoverPolicyType) - Method in interface org.apache.pulsar.common.policies.data.AutoFailoverPolicyData.Builder
 
PoolArenaStats() - Constructor for class org.apache.pulsar.common.stats.AllocatorStats.PoolArenaStats
 
PoolChunkListStats() - Constructor for class org.apache.pulsar.common.stats.AllocatorStats.PoolChunkListStats
 
PoolChunkStats() - Constructor for class org.apache.pulsar.common.stats.AllocatorStats.PoolChunkStats
 
PoolSubpageStats() - Constructor for class org.apache.pulsar.common.stats.AllocatorStats.PoolSubpageStats
 
PositionInPendingAckStats - Class in org.apache.pulsar.common.stats
 
PositionInPendingAckStats() - Constructor for class org.apache.pulsar.common.stats.PositionInPendingAckStats
 
PositionInPendingAckStats(PositionInPendingAckStats.State) - Constructor for class org.apache.pulsar.common.stats.PositionInPendingAckStats
 
PositionInPendingAckStats.State - Enum Class in org.apache.pulsar.common.stats
 
PostSchemaPayload - Class in org.apache.pulsar.common.protocol.schema
Payload with information about a schema.
PostSchemaPayload() - Constructor for class org.apache.pulsar.common.protocol.schema.PostSchemaPayload
 
PreconditionFailedException(Throwable, String, int) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.PreconditionFailedException
 
Prefix - Enum constant in enum class org.apache.pulsar.common.policies.data.SubscriptionAuthMode
Subscription name with auth role prefix can be used by the role.
primary - Enum constant in enum class org.apache.pulsar.common.policies.data.BrokerAssignment
 
primary(boolean) - Method in interface org.apache.pulsar.common.policies.data.BrokerNamespaceIsolationData.Builder
 
primary(List<String>) - Method in interface org.apache.pulsar.common.policies.data.NamespaceIsolationData.Builder
 
produce - Enum constant in enum class org.apache.pulsar.common.policies.data.AuthAction
Permission to produce/publish messages.
producedPartitions - Variable in class org.apache.pulsar.common.policies.data.TransactionMetadata
The producedPartitions of this transaction.
producer_exception - Enum constant in enum class org.apache.pulsar.common.policies.data.BacklogQuota.RetentionPolicy
Policy which throws javax.jms.ResourceAllocationException to the producer.
producer_request_hold - Enum constant in enum class org.apache.pulsar.common.policies.data.BacklogQuota.RetentionPolicy
Policy which holds producer's send request until the resource becomes available (or holding times out).
ProducerConfig - Class in org.apache.pulsar.common.functions
Configuration of the producer inside the function.
ProducerConfig() - Constructor for class org.apache.pulsar.common.functions.ProducerConfig
 
producerCount - Variable in class org.apache.pulsar.policies.data.loadbalancer.NamespaceBundleStats
 
properties - Variable in class org.apache.pulsar.common.partition.PartitionedTopicMetadata
 
properties - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.CursorStats
 
properties - Variable in class org.apache.pulsar.common.policies.data.Policies
 
properties() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
Deprecated.
since 2.0. See PulsarAdmin.tenants()
Properties - Interface in org.apache.pulsar.client.admin
Deprecated.
proxyProtocol(ProxyProtocol) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
 
proxyServiceUrl(String) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
 
proxyStats() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
 
ProxyStats - Interface in org.apache.pulsar.client.admin
Admin interface for proxy stats management.
PublisherStats - Interface in org.apache.pulsar.common.policies.data
Statistics about a publisher.
publishMaxMessageRate - Variable in class org.apache.pulsar.common.policies.data.Policies
 
PublishRate - Class in org.apache.pulsar.common.policies.data
Publish-rate to manage publish throttling.
PublishRate() - Constructor for class org.apache.pulsar.common.policies.data.PublishRate
 
PublishRate(int, long) - Constructor for class org.apache.pulsar.common.policies.data.PublishRate
 
publishThrottlingRateInByte - Variable in class org.apache.pulsar.common.policies.data.PublishRate
 
publishThrottlingRateInMsg - Variable in class org.apache.pulsar.common.policies.data.PublishRate
 
PulsarAdmin - Interface in org.apache.pulsar.client.admin
 
PulsarAdminBuilder - Interface in org.apache.pulsar.client.admin
Builder class for a PulsarAdmin instance.
PulsarAdminException - Exception in org.apache.pulsar.client.admin
Pulsar admin exceptions.
PulsarAdminException(String) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException
 
PulsarAdminException(String, Throwable) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException
 
PulsarAdminException(String, Throwable, String, int) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException
 
PulsarAdminException(Throwable) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException
 
PulsarAdminException(Throwable, String, int) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException
 
PulsarAdminException.ConflictException - Exception in org.apache.pulsar.client.admin
Conflict Exception.
PulsarAdminException.ConnectException - Exception in org.apache.pulsar.client.admin
Connect Exception.
PulsarAdminException.GettingAuthenticationDataException - Exception in org.apache.pulsar.client.admin
Getting Authentication Data Exception.
PulsarAdminException.HttpErrorException - Exception in org.apache.pulsar.client.admin
Http Error Exception.
PulsarAdminException.NotAllowedException - Exception in org.apache.pulsar.client.admin
Not Allowed Exception.
PulsarAdminException.NotAuthorizedException - Exception in org.apache.pulsar.client.admin
Not Authorized Exception.
PulsarAdminException.NotFoundException - Exception in org.apache.pulsar.client.admin
Not Found Exception.
PulsarAdminException.PreconditionFailedException - Exception in org.apache.pulsar.client.admin
Precondition Failed Exception.
PulsarAdminException.ServerSideErrorException - Exception in org.apache.pulsar.client.admin
Server Side Error Exception.
PulsarAdminException.TimeoutException - Exception in org.apache.pulsar.client.admin
Timeout Exception.
put(String, Object) - Method in class org.apache.pulsar.common.stats.Metrics
 
putAll(Map<String, Object>) - Method in class org.apache.pulsar.common.stats.Metrics
 
putFunctionState(String, String, String, FunctionState) - Method in interface org.apache.pulsar.client.admin.Functions
Puts the given state associated with a Pulsar Function.
putFunctionStateAsync(String, String, String, FunctionState) - Method in interface org.apache.pulsar.client.admin.Functions
Puts the given state associated with a Pulsar Function asynchronously.
PYTHON - Enum constant in enum class org.apache.pulsar.common.functions.FunctionConfig.Runtime
 

R

rack(String) - Method in interface org.apache.pulsar.common.policies.data.BookieInfo.Builder
 
rack(String) - Method in class org.apache.pulsar.common.policies.data.impl.BookieInfoImpl.BookieInfoImplBuilder
 
ratePeriodInSecond - Variable in class org.apache.pulsar.common.policies.data.SubscribeRate
 
ratePeriodInSecond(int) - Method in interface org.apache.pulsar.common.policies.data.DispatchRate.Builder
 
ratePeriodInSecond(int) - Method in class org.apache.pulsar.common.policies.data.impl.DispatchRateImpl.DispatchRateImplBuilder
 
RawBookieInfo - Class in org.apache.pulsar.common.policies.data
Bookie information.
RawBookieInfo() - Constructor for class org.apache.pulsar.common.policies.data.RawBookieInfo
 
readPosition - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.CursorStats
 
readTimeout(int, TimeUnit) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder
This sets the server response read time out for the pulsar admin client for any request.
reason - Variable in class org.apache.pulsar.common.policies.data.ErrorData
 
rebalance() - Method in interface org.apache.pulsar.client.admin.Worker
Triggers a rebalance of functions to workers.
rebalanceAsync() - Method in interface org.apache.pulsar.client.admin.Worker
Triggers a rebalance of functions to workersasynchronously..
recoverEndTime - Variable in class org.apache.pulsar.common.policies.data.TransactionBufferStats
 
recoverEndTime - Variable in class org.apache.pulsar.common.policies.data.TransactionCoordinatorStats
 
recoverEndTime - Variable in class org.apache.pulsar.common.policies.data.TransactionPendingAckStats
 
recoverStartTime - Variable in class org.apache.pulsar.common.policies.data.TransactionBufferStats
 
recoverStartTime - Variable in class org.apache.pulsar.common.policies.data.TransactionCoordinatorStats
 
recoverStartTime - Variable in class org.apache.pulsar.common.policies.data.TransactionPendingAckStats
 
ReflectionUtils - Class in org.apache.pulsar.client.admin.utils
 
ReflectionUtils() - Constructor for class org.apache.pulsar.client.admin.utils.ReflectionUtils
 
relativeToPublishRate(boolean) - Method in interface org.apache.pulsar.common.policies.data.DispatchRate.Builder
 
relativeToPublishRate(boolean) - Method in class org.apache.pulsar.common.policies.data.impl.DispatchRateImpl.DispatchRateImplBuilder
 
reloadBuiltInFunctions() - Method in interface org.apache.pulsar.client.admin.Functions
Reload the available built-in functions.
reloadBuiltInFunctionsAsync() - Method in interface org.apache.pulsar.client.admin.Functions
Reload the available built-in functions.
reloadBuiltInSinks() - Method in interface org.apache.pulsar.client.admin.Sinks
Reload the available built-in connectors, include Source and Sink.
reloadBuiltInSinksAsync() - Method in interface org.apache.pulsar.client.admin.Sinks
Reload the available built-in connectors, include Source and Sink asynchronously.
reloadBuiltInSources() - Method in interface org.apache.pulsar.client.admin.Sources
Reload the available built-in connectors, include Source and Source.
reloadBuiltInSourcesAsync() - Method in interface org.apache.pulsar.client.admin.Sources
Reload the available built-in connectors, include Source and Source asynchronously.
removeAutoSubscriptionCreation(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Removes the autoSubscriptionCreation policy for a given namespace.
removeAutoSubscriptionCreation(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Removes the autoSubscriptionCreation policy for a given topic.
removeAutoSubscriptionCreationAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Removes the autoSubscriptionCreation policy for a given namespace asynchronously.
removeAutoSubscriptionCreationAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Removes the autoSubscriptionCreation policy for a given topic asynchronously.
removeAutoTopicCreation(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Removes the autoTopicCreation policy for a given namespace.
removeAutoTopicCreationAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Removes the autoTopicCreation policy for a given namespace asynchronously.
removeBacklogQuota(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
 
removeBacklogQuota(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
 
removeBacklogQuota(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeBacklogQuota(String, BacklogQuota.BacklogQuotaType) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove a backlog quota policy from a namespace.
removeBacklogQuota(String, BacklogQuota.BacklogQuotaType) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove a backlog quota policy from a topic.
removeBacklogQuota(String, BacklogQuota.BacklogQuotaType) - Method in interface org.apache.pulsar.client.admin.Topics
removeBacklogQuotaAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
 
removeBacklogQuotaAsync(String, BacklogQuota.BacklogQuotaType) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove a backlog quota policy from a namespace asynchronously.
removeBookie(String) - Method in class org.apache.pulsar.common.policies.data.BookiesRackConfiguration
 
removeCompactionThreshold(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Delete the compactionThreshold for a namespace.
removeCompactionThreshold(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove the compactionThreshold for a topic.
removeCompactionThreshold(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeCompactionThresholdAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Delete the compactionThreshold for a namespace asynchronously.
removeCompactionThresholdAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove the compactionThreshold for a topic asynchronously.
removeCompactionThresholdAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeDeduplicationSnapshotInterval(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove the deduplicationSnapshotInterval for a namespace.
removeDeduplicationSnapshotInterval(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove the deduplication snapshot interval for specified topic.
removeDeduplicationSnapshotInterval(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeDeduplicationSnapshotIntervalAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove the deduplicationSnapshotInterval for a namespace asynchronously.
removeDeduplicationSnapshotIntervalAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove the deduplication snapshot interval for specified topic asynchronously.
removeDeduplicationSnapshotIntervalAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeDeduplicationStatus(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove the deduplication status for all topics within a namespace.
removeDeduplicationStatus(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
remove deduplication enabled of a topic.
removeDeduplicationStatus(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeDeduplicationStatusAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the deduplication status for all topics within a namespace asynchronously.
removeDeduplicationStatusAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
remove deduplication enabled of a topic asynchronously.
removeDeduplicationStatusAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeDelayedDeliveryMessages(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove the delayed delivery messages for all topics within a namespace.
removeDelayedDeliveryMessagesAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove the delayed delivery messages for all topics within a namespace asynchronously.
removeDelayedDeliveryPolicy(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove the delayed delivery policy for a specified topic.
removeDelayedDeliveryPolicy(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeDelayedDeliveryPolicyAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove the delayed delivery policy for a specified topic asynchronously.
removeDelayedDeliveryPolicyAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove message-dispatch-rate.
removeDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove message-dispatch-rate.
removeDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeDispatchRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove message-dispatch-rate asynchronously.
removeDispatchRateAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove message-dispatch-rate asynchronously.
removeDispatchRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeEntryFiltersPerTopic(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
remove entry filters of a topic.
removeEntryFiltersPerTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
remove entry filters of a topic asynchronously.
removeInactiveTopicPolicies(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove inactive topic policies from a namespace.
removeInactiveTopicPolicies(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
remove inactive topic policies of a topic.
removeInactiveTopicPolicies(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeInactiveTopicPoliciesAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
remove InactiveTopicPolicies from a namespace asynchronously.
removeInactiveTopicPoliciesAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
remove inactive topic policies of a topic asynchronously.
removeInactiveTopicPoliciesAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeMaxConsumers(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove the max number of consumer for specified topic.
removeMaxConsumers(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeMaxConsumersAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove the max number of consumer for specified topic asynchronously.
removeMaxConsumersAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeMaxConsumersPerSubscription(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove maxConsumersPerSubscription for a namespace.
removeMaxConsumersPerSubscription(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove the maxConsumersPerSubscription for a topic.
removeMaxConsumersPerSubscription(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeMaxConsumersPerSubscriptionAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove maxConsumersPerSubscription for a namespace asynchronously.
removeMaxConsumersPerSubscriptionAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove the maxConsumersPerSubscription for a topic asynchronously.
removeMaxConsumersPerSubscriptionAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeMaxConsumersPerTopic(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove maxConsumersPerTopic for a namespace.
removeMaxConsumersPerTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove maxConsumersPerTopic for a namespace asynchronously.
removeMaxMessageSize(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove the max message size for specified topic.
removeMaxMessageSize(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeMaxMessageSizeAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove the max message size for specified topic asynchronously.
removeMaxMessageSizeAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeMaxProducers(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove the max number of producer for specified topic.
removeMaxProducers(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeMaxProducersAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove the max number of producer for specified topic asynchronously.
removeMaxProducersAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeMaxProducersPerTopic(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove maxProducersPerTopic for a namespace.
removeMaxProducersPerTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set maxProducersPerTopic for a namespace asynchronously.
removeMaxSubscriptionsPerTopic(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove the maxSubscriptionsPerTopic for a namespace.
removeMaxSubscriptionsPerTopic(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove the max number of subscriptions for specified topic.
removeMaxSubscriptionsPerTopic(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeMaxSubscriptionsPerTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove the maxSubscriptionsPerTopic for a namespace asynchronously.
removeMaxSubscriptionsPerTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove the max number of subscriptions for specified topic asynchronously.
removeMaxSubscriptionsPerTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeMaxTopicsPerNamespace(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
remove maxTopicsPerNamespace for a namespace.
removeMaxTopicsPerNamespaceAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
remove maxTopicsPerNamespace for a namespace asynchronously.
removeMaxUnackedMessagesOnConsumer(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
remove max unacked messages on consumer of a topic.
removeMaxUnackedMessagesOnConsumer(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeMaxUnackedMessagesOnConsumerAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
remove max unacked messages on consumer of a topic asynchronously.
removeMaxUnackedMessagesOnConsumerAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeMaxUnackedMessagesOnSubscription(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
remove max unacked messages on subscription of a topic.
removeMaxUnackedMessagesOnSubscription(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeMaxUnackedMessagesOnSubscriptionAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
remove max unacked messages on subscription of a topic asynchronously.
removeMaxUnackedMessagesOnSubscriptionAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeMaxUnackedMessagesPerConsumer(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove maxUnackedMessagesPerConsumer for a namespace.
removeMaxUnackedMessagesPerConsumerAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove maxUnackedMessagesPerConsumer for a namespace asynchronously.
removeMaxUnackedMessagesPerSubscription(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove maxUnackedMessagesPerSubscription for a namespace.
removeMaxUnackedMessagesPerSubscriptionAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove maxUnackedMessagesPerSubscription for a namespace asynchronously.
removeMessageTTL(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove message TTL for a topic.
removeMessageTTL(String) - Method in interface org.apache.pulsar.client.admin.Topics
Deprecated.
removeNamespaceEntryFilters(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
remove entry filters of a namespace.
removeNamespaceEntryFiltersAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
remove entry filters of a namespace asynchronously.
removeNamespaceMessageTTL(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove the messages Time to Live for all the topics within a namespace.
removeNamespaceMessageTTLAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove the messages Time to Live for all the topics within a namespace asynchronously.
removeNamespaceResourceGroup(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove the ResourceGroup on a namespace.
removeNamespaceResourceGroupAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove the ResourceGroup on a namespace asynchronously.
removeOffloadPolicies(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove the offload configuration for a namespace.
removeOffloadPolicies(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
remove offload policies of a topic.
removeOffloadPolicies(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeOffloadPoliciesAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove the offload configuration for a namespace asynchronously.
removeOffloadPoliciesAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
remove offload policies of a topic asynchronously.
removeOffloadPoliciesAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
removePersistence(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove the persistence configuration on a namespace.
removePersistence(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove the configuration of persistence policies for specified topic.
removePersistence(String) - Method in interface org.apache.pulsar.client.admin.Topics
Deprecated.
removePersistenceAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove the persistence configuration on a namespace asynchronously.
removePersistenceAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove the configuration of persistence policies for specified topic asynchronously.
removePersistenceAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeProperties(String, String) - Method in interface org.apache.pulsar.client.admin.Topics
Remove the key in properties on a topic.
removePropertiesAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Topics
Remove the key in properties on a topic asynchronously.
removeProperty(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove a property for a given key.
removePropertyAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove a property for a given key.
removePublishRate(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove message-publish-rate (topics under this namespace can publish this many messages per second).
removePublishRate(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove message-publish-rate.
removePublishRate(String) - Method in interface org.apache.pulsar.client.admin.Topics
Deprecated.
removePublishRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove message-publish-rate asynchronously.
removePublishRateAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove message-publish-rate asynchronously.
removePublishRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeReplicationClusters(String) - Method in interface org.apache.pulsar.client.admin.Topics
Remove the replication clusters for the topic.
removeReplicationClustersAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
Remove the replication clusters for the topic asynchronously.
removeReplicatorDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove replicator-message-dispatch-rate.
removeReplicatorDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove replicatorDispatchRate for a topic.
removeReplicatorDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeReplicatorDispatchRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set replicator-message-dispatch-rate asynchronously.
removeReplicatorDispatchRateAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove replicatorDispatchRate for a topic asynchronously.
removeReplicatorDispatchRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeRetention(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove the retention configuration for all the topics on a namespace.
removeRetention(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove the retention configuration for all the topics on a topic.
removeRetention(String) - Method in interface org.apache.pulsar.client.admin.Topics
Deprecated.
removeRetentionAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove the retention configuration for all the topics on a namespace asynchronously.
removeRetentionAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove the retention configuration for all the topics on a topic asynchronously.
removeRetentionAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeSchemaCompatibilityStrategy(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove schema compatibility strategy on a topic.
removeSchemaCompatibilityStrategyAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove schema compatibility strategy on a topic asynchronously.
removeShadowTopics(String) - Method in interface org.apache.pulsar.client.admin.Topics
Remove all shadow topics for a source topic.
removeShadowTopicsAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
Remove all shadow topics for a source topic asynchronously.
removeSubscribeRate(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove namespace-subscribe-rate (topics under this namespace will limit by subscribeRate).
removeSubscribeRate(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove topic-subscribe-rate.
removeSubscribeRate(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeSubscribeRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove namespace-subscribe-rate (topics under this namespace will limit by subscribeRate) asynchronously.
removeSubscribeRateAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove topic-subscribe-rate asynchronously.
removeSubscribeRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeSubscriptionDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove subscription-message-dispatch-rate.
removeSubscriptionDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove subscription-message-dispatch-rate for a topic.
removeSubscriptionDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeSubscriptionDispatchRate(String, String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove subscription level dispatch rate limiter setting for a specific subscription.
removeSubscriptionDispatchRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove subscription-message-dispatch-rate asynchronously.
removeSubscriptionDispatchRateAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove subscription-message-dispatch-rate for a topic asynchronously.
removeSubscriptionDispatchRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeSubscriptionDispatchRateAsync(String, String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
removeSubscriptionExpirationTime(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove the subscription expiration time for a namespace.
removeSubscriptionExpirationTimeAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove the subscription expiration time for a namespace asynchronously.
removeSubscriptionTypesEnabled(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Removes the subscriptionTypesEnabled policy for a given namespace.
removeSubscriptionTypesEnabled(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove subscription types enabled for a topic.
removeSubscriptionTypesEnabled(String) - Method in interface org.apache.pulsar.client.admin.Topics
removeSubscriptionTypesEnabledAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Removes the subscriptionTypesEnabled policy for a given namespace.
removeSubscriptionTypesEnabledAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Remove subscription types enabled for a topic asynchronously.
removeSubscriptionTypesEnabledAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
replication_clusters - Variable in class org.apache.pulsar.common.policies.data.Policies
 
replicatorDispatchRate - Variable in class org.apache.pulsar.common.policies.data.Policies
 
ReplicatorStats - Interface in org.apache.pulsar.common.policies.data
Statistics about a replicator.
requestTimeout(int, TimeUnit) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder
This sets the server request time out for the pulsar admin client for any request.
reset() - Method in class org.apache.pulsar.common.policies.data.PartitionedTopicInternalStats
 
reset() - Method in class org.apache.pulsar.policies.data.loadbalancer.NamespaceBundleStats
 
resetCursor(String, String, long) - Method in interface org.apache.pulsar.client.admin.Topics
Reset cursor position on a topic subscription.
resetCursor(String, String, MessageId) - Method in interface org.apache.pulsar.client.admin.Topics
Reset cursor position on a topic subscription.
resetCursor(String, String, MessageId, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
Reset cursor position on a topic subscription.
resetCursorAsync(String, String, long) - Method in interface org.apache.pulsar.client.admin.Topics
Reset cursor position on a topic subscription.
resetCursorAsync(String, String, MessageId) - Method in interface org.apache.pulsar.client.admin.Topics
Reset cursor position on a topic subscription.
resetCursorAsync(String, String, MessageId, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
Reset cursor position on a topic subscription.
resetNamespaceBundleResourceQuota(String, String) - Method in interface org.apache.pulsar.client.admin.ResourceQuotas
Reset resource quota for a namespace bundle to default value.
resetNamespaceBundleResourceQuotaAsync(String, String) - Method in interface org.apache.pulsar.client.admin.ResourceQuotas
Reset resource quota for a namespace bundle to default value asynchronously.
resource_group_name - Variable in class org.apache.pulsar.common.policies.data.Policies
 
ResourceGroup - Class in org.apache.pulsar.common.policies.data
 
ResourceGroup() - Constructor for class org.apache.pulsar.common.policies.data.ResourceGroup
 
resourcegroups() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
 
ResourceGroups - Interface in org.apache.pulsar.client.admin
Admin interface for ResourceGroups management.
ResourceQuota - Class in org.apache.pulsar.common.policies.data
Resource quota for a namespace or namespace bundle.
ResourceQuota() - Constructor for class org.apache.pulsar.common.policies.data.ResourceQuota
 
resourceQuotas() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
 
ResourceQuotas - Interface in org.apache.pulsar.client.admin
Admin interface on interacting with resource quotas.
Resources - Class in org.apache.pulsar.common.functions
Class representing resources, such as CPU, RAM, and disk size.
Resources() - Constructor for class org.apache.pulsar.common.functions.Resources
 
ResourceUsage - Class in org.apache.pulsar.policies.data.loadbalancer
POJO used to represent any system specific resource usage this is the format that load manager expects it in.
ResourceUsage() - Constructor for class org.apache.pulsar.policies.data.loadbalancer.ResourceUsage
 
ResourceUsage(double, double) - Constructor for class org.apache.pulsar.policies.data.loadbalancer.ResourceUsage
 
restartFunction(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions
Restart all function instances.
restartFunction(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Functions
Restart function instance.
restartFunctionAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions
Restart all function instances asynchronously.
restartFunctionAsync(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Functions
Restart function instance asynchronously.
restartSink(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sinks
Restart all sink instances.
restartSink(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sinks
Restart sink instance.
restartSinkAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sinks
Restart all sink instances asynchronously.
restartSinkAsync(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sinks
Restart sink instance asynchronously.
restartSource(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sources
Restart all source instances.
restartSource(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sources
Restart source instance.
restartSourceAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sources
Restart all source instances asynchronously.
restartSourceAsync(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sources
Restart source instance asynchronously.
retention_policies - Variable in class org.apache.pulsar.common.policies.data.Policies
 
RetentionPolicies - Class in org.apache.pulsar.common.policies.data
Definition of the retention policy.
RetentionPolicies() - Constructor for class org.apache.pulsar.common.policies.data.RetentionPolicies
 
RetentionPolicies(int, long) - Constructor for class org.apache.pulsar.common.policies.data.RetentionPolicies
 
retentionPolicy(BacklogQuota.RetentionPolicy) - Method in interface org.apache.pulsar.common.policies.data.BacklogQuota.Builder
 
retentionPolicy(BacklogQuota.RetentionPolicy) - Method in class org.apache.pulsar.common.policies.data.impl.BacklogQuotaImpl.BacklogQuotaImplBuilder
 
revokePermissionOnSubscription(String, String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Revoke permissions on a subscription's admin-api access.
revokePermissionOnSubscriptionAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Revoke permissions on a subscription's admin-api access asynchronously.
revokePermissions(String, String) - Method in interface org.apache.pulsar.client.admin.Topics
Revoke permissions on a topic.
revokePermissionsAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Topics
Revoke permissions on a topic asynchronously.
revokePermissionsOnNamespace(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Revoke permissions on a namespace.
revokePermissionsOnNamespaceAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Revoke permissions on a namespace asynchronously.
running - Variable in class org.apache.pulsar.common.policies.data.FunctionStatus.FunctionInstanceStatus.FunctionInstanceStatusData
 
running - Variable in class org.apache.pulsar.common.policies.data.SinkStatus.SinkInstanceStatus.SinkInstanceStatusData
 
running - Variable in class org.apache.pulsar.common.policies.data.SourceStatus.SourceInstanceStatus.SourceInstanceStatusData
 
RUNNING - Enum constant in enum class org.apache.pulsar.client.admin.LongRunningProcessStatus.Status
 

S

s3ManagedLedgerOffloadBucket(String) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
 
s3ManagedLedgerOffloadCredentialId(String) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
 
s3ManagedLedgerOffloadCredentialSecret(String) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
 
s3ManagedLedgerOffloadMaxBlockSizeInBytes(Integer) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
 
s3ManagedLedgerOffloadReadBufferSizeInBytes(Integer) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
 
s3ManagedLedgerOffloadRegion(String) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
 
s3ManagedLedgerOffloadRole(String) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
 
s3ManagedLedgerOffloadServiceEndpoint(String) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
 
scaleTransactionCoordinators(int) - Method in interface org.apache.pulsar.client.admin.Transactions
Sets the scale of the transaction coordinators.
scaleTransactionCoordinatorsAsync(int) - Method in interface org.apache.pulsar.client.admin.Transactions
Asynchronously sets the size of the transaction coordinators.
schema_auto_update_compatibility_strategy - Variable in class org.apache.pulsar.common.policies.data.Policies
Deprecated.
schema_compatibility_strategy - Variable in class org.apache.pulsar.common.policies.data.Policies
 
schema_validation_enforced - Variable in class org.apache.pulsar.common.policies.data.Policies
 
SchemaAutoUpdateCompatibilityStrategy - Enum Class in org.apache.pulsar.common.policies.data
Strategy to use when checking an auto-updated schema for compatibility to the current schema.
SchemaCompatibilityStrategy - Enum Class in org.apache.pulsar.common.policies.data
Pulsar Schema compatibility strategy.
schemaLedgers - Variable in class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats
 
schemas() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
 
Schemas - Interface in org.apache.pulsar.client.admin
Admin interface on interacting with schemas.
secondary - Enum constant in enum class org.apache.pulsar.common.policies.data.BrokerAssignment
 
secondary(List<String>) - Method in interface org.apache.pulsar.common.policies.data.NamespaceIsolationData.Builder
 
segmentIndexInternalStats - Variable in class org.apache.pulsar.common.policies.data.TransactionBufferInternalStats
 
segmentInternalStats - Variable in class org.apache.pulsar.common.policies.data.TransactionBufferInternalStats
 
segmentsSize - Variable in class org.apache.pulsar.common.policies.data.SegmentsStats
 
segmentsStats - Variable in class org.apache.pulsar.common.policies.data.TransactionBufferStats
 
SegmentsStats - Class in org.apache.pulsar.common.policies.data
 
SegmentsStats() - Constructor for class org.apache.pulsar.common.policies.data.SegmentsStats
 
segmentStats - Variable in class org.apache.pulsar.common.policies.data.SegmentsStats
 
SegmentStats - Class in org.apache.pulsar.common.policies.data
 
SegmentStats() - Constructor for class org.apache.pulsar.common.policies.data.SegmentStats
 
SegmentStats(String, String) - Constructor for class org.apache.pulsar.common.policies.data.SegmentStats
 
ServerSideErrorException(Throwable) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.ServerSideErrorException
Deprecated.
ServerSideErrorException(Throwable, String, String, int) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.ServerSideErrorException
 
serviceHttpUrl(String) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder
Set the Pulsar service HTTP URL for the admin endpoint (eg.
ServiceLookupData - Interface in org.apache.pulsar.policies.data.loadbalancer
For backwards compatibility purposes.
serviceUrl(String) - Method in interface org.apache.pulsar.common.policies.data.BrokerInfo.Builder
 
serviceUrl(String) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
 
serviceUrl(String) - Method in class org.apache.pulsar.common.policies.data.impl.BrokerInfoImpl.BrokerInfoImplBuilder
 
serviceUrlTls(String) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
 
setAutoSubscriptionCreation(String, AutoSubscriptionCreationOverride) - Method in interface org.apache.pulsar.client.admin.Namespaces
Sets the autoSubscriptionCreation policy for a given namespace, overriding broker settings.
setAutoSubscriptionCreation(String, AutoSubscriptionCreationOverride) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Sets the autoSubscriptionCreation policy for a given topic, overriding namespace settings.
setAutoSubscriptionCreationAsync(String, AutoSubscriptionCreationOverride) - Method in interface org.apache.pulsar.client.admin.Namespaces
Sets the autoSubscriptionCreation policy for a given namespace, overriding broker settings asynchronously.
setAutoSubscriptionCreationAsync(String, AutoSubscriptionCreationOverride) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Sets the autoSubscriptionCreation policy for a given topic, overriding namespace settings asynchronously.
setAutoTopicCreation(String, AutoTopicCreationOverride) - Method in interface org.apache.pulsar.client.admin.Namespaces
Sets the autoTopicCreation policy for a given namespace, overriding broker settings.
setAutoTopicCreationAsync(String, AutoTopicCreationOverride) - Method in interface org.apache.pulsar.client.admin.Namespaces
Sets the autoTopicCreation policy for a given namespace, overriding broker settings asynchronously.
setBacklogQuota(String, BacklogQuota) - Method in interface org.apache.pulsar.client.admin.Namespaces
 
setBacklogQuota(String, BacklogQuota) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
 
setBacklogQuota(String, BacklogQuota) - Method in interface org.apache.pulsar.client.admin.Topics
setBacklogQuota(String, BacklogQuota, BacklogQuota.BacklogQuotaType) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set a backlog quota for all the topics on a namespace.
setBacklogQuota(String, BacklogQuota, BacklogQuota.BacklogQuotaType) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set a backlog quota for a topic.
setBacklogQuota(String, BacklogQuota, BacklogQuota.BacklogQuotaType) - Method in interface org.apache.pulsar.client.admin.Topics
setBacklogQuotaAsync(String, BacklogQuota) - Method in interface org.apache.pulsar.client.admin.Namespaces
 
setBacklogQuotaAsync(String, BacklogQuota, BacklogQuota.BacklogQuotaType) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set a backlog quota for all the topics on a namespace asynchronously.
setBookieAffinityGroup(String, BookieAffinityGroupData) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set bookie affinity group for a namespace to isolate namespace write to bookies that are part of given affinity group.
setBookieAffinityGroupAsync(String, BookieAffinityGroupData) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set bookie affinity group for a namespace to isolate namespace write to bookies that are part of given affinity group asynchronously.
setCompactionThreshold(String, long) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the compactionThreshold for a namespace.
setCompactionThreshold(String, long) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set the compactionThreshold for a topic.
setCompactionThreshold(String, long) - Method in interface org.apache.pulsar.client.admin.Topics
setCompactionThresholdAsync(String, long) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the compactionThreshold for a namespace asynchronously.
setCompactionThresholdAsync(String, long) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set the compactionThreshold for a topic asynchronously.
setCompactionThresholdAsync(String, long) - Method in interface org.apache.pulsar.client.admin.Topics
setConfigurationStoreServers(String) - Method in class org.apache.pulsar.common.conf.InternalConfigurationData
Deprecated.
setContextClassLoader(ClassLoader) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder
 
setDeduplicationSnapshotInterval(String, int) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set the deduplication snapshot interval for specified topic.
setDeduplicationSnapshotInterval(String, int) - Method in interface org.apache.pulsar.client.admin.Topics
setDeduplicationSnapshotInterval(String, Integer) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the deduplicationSnapshotInterval for a namespace.
setDeduplicationSnapshotIntervalAsync(String, int) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set the deduplication snapshot interval for specified topic asynchronously.
setDeduplicationSnapshotIntervalAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Topics
setDeduplicationSnapshotIntervalAsync(String, Integer) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the deduplicationSnapshotInterval for a namespace asynchronously.
setDeduplicationStatus(String, boolean) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the deduplication status for all topics within a namespace.
setDeduplicationStatus(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
set deduplication enabled of a topic.
setDeduplicationStatus(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
setDeduplicationStatusAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the deduplication status for all topics within a namespace asynchronously.
setDeduplicationStatusAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
set deduplication enabled of a topic asynchronously.
setDeduplicationStatusAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
setDefaultResourceQuota(ResourceQuota) - Method in interface org.apache.pulsar.client.admin.ResourceQuotas
Set default resource quota for new namespace bundles.
setDefaultResourceQuotaAsync(ResourceQuota) - Method in interface org.apache.pulsar.client.admin.ResourceQuotas
Set default resource quota for new namespace bundles asynchronously.
setDelayedDeliveryMessages(String, DelayedDeliveryPolicies) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the delayed delivery messages for all topics within a namespace.
setDelayedDeliveryMessagesAsync(String, DelayedDeliveryPolicies) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the delayed delivery messages for all topics within a namespace asynchronously.
setDelayedDeliveryPolicy(String, DelayedDeliveryPolicies) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set the delayed delivery policy for a specified topic.
setDelayedDeliveryPolicy(String, DelayedDeliveryPolicies) - Method in interface org.apache.pulsar.client.admin.Topics
setDelayedDeliveryPolicyAsync(String, DelayedDeliveryPolicies) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set the delayed delivery policy for a specified topic asynchronously.
setDelayedDeliveryPolicyAsync(String, DelayedDeliveryPolicies) - Method in interface org.apache.pulsar.client.admin.Topics
setDispatchRate(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set message-dispatch-rate (topics under this namespace can dispatch this many messages per second).
setDispatchRate(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set message-dispatch-rate (topic can dispatch this many messages per second).
setDispatchRate(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.Topics
setDispatchRateAsync(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set message-dispatch-rate asynchronously.
setDispatchRateAsync(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set message-dispatch-rate asynchronously.
setDispatchRateAsync(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.Topics
setEncryptionRequiredStatus(String, boolean) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the encryption required status for all topics within a namespace.
setEncryptionRequiredStatusAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the encryption required status for all topics within a namespace asynchronously.
setEntryFiltersPerTopic(String, EntryFilters) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set entry filters on a topic.
setEntryFiltersPerTopicAsync(String, EntryFilters) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set entry filters on a topic asynchronously.
setInactiveTopicPolicies(String, InactiveTopicPolicies) - Method in interface org.apache.pulsar.client.admin.Namespaces
As same as setInactiveTopicPoliciesAsync, but it is synchronous.
setInactiveTopicPolicies(String, InactiveTopicPolicies) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
set inactive topic policies of a topic.
setInactiveTopicPolicies(String, InactiveTopicPolicies) - Method in interface org.apache.pulsar.client.admin.Topics
setInactiveTopicPoliciesAsync(String, InactiveTopicPolicies) - Method in interface org.apache.pulsar.client.admin.Namespaces
You can set the inactive deletion strategy at the namespace level.
setInactiveTopicPoliciesAsync(String, InactiveTopicPolicies) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
set inactive topic policies of a topic asynchronously.
setInactiveTopicPoliciesAsync(String, InactiveTopicPolicies) - Method in interface org.apache.pulsar.client.admin.Topics
setIsAllowAutoUpdateSchema(String, boolean) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set whether to allow automatic schema updates.
setIsAllowAutoUpdateSchemaAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set whether to allow automatic schema updates asynchronously.
setLimit(long) - Method in class org.apache.pulsar.common.policies.data.impl.BacklogQuotaImpl
Deprecated.
setLimitSize(long) - Method in class org.apache.pulsar.common.policies.data.impl.BacklogQuotaImpl
 
setLimitTime(int) - Method in class org.apache.pulsar.common.policies.data.impl.BacklogQuotaImpl
 
setMaxConsumers(String, int) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set the max number of consumer for specified topic.
setMaxConsumers(String, int) - Method in interface org.apache.pulsar.client.admin.Topics
setMaxConsumersAsync(String, int) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set the max number of consumer for specified topic asynchronously.
setMaxConsumersAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Topics
setMaxConsumersPerSubscription(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set maxConsumersPerSubscription for a namespace.
setMaxConsumersPerSubscription(String, int) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set maxConsumersPerSubscription for a topic.
setMaxConsumersPerSubscription(String, int) - Method in interface org.apache.pulsar.client.admin.Topics
setMaxConsumersPerSubscriptionAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set maxConsumersPerSubscription for a namespace asynchronously.
setMaxConsumersPerSubscriptionAsync(String, int) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set maxConsumersPerSubscription for a topic asynchronously.
setMaxConsumersPerSubscriptionAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Topics
setMaxConsumersPerTopic(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set maxConsumersPerTopic for a namespace.
setMaxConsumersPerTopicAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set maxConsumersPerTopic for a namespace asynchronously.
setMaxMessageSize(String, int) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set the max message size for specified topic.
setMaxMessageSize(String, int) - Method in interface org.apache.pulsar.client.admin.Topics
setMaxMessageSizeAsync(String, int) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set the max message size for specified topic asynchronously.0 disables.
setMaxMessageSizeAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Topics
setMaxProducers(String, int) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set the max number of producer for specified topic.
setMaxProducers(String, int) - Method in interface org.apache.pulsar.client.admin.Topics
setMaxProducersAsync(String, int) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set the max number of producer for specified topic asynchronously.
setMaxProducersAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Topics
setMaxProducersPerTopic(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set maxProducersPerTopic for a namespace.
setMaxProducersPerTopicAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set maxProducersPerTopic for a namespace asynchronously.
setMaxSubscriptionsPerTopic(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the maxSubscriptionsPerTopic for a namespace.
setMaxSubscriptionsPerTopic(String, int) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set the max number of subscriptions for specified topic.
setMaxSubscriptionsPerTopic(String, int) - Method in interface org.apache.pulsar.client.admin.Topics
setMaxSubscriptionsPerTopicAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the maxSubscriptionsPerTopic for a namespace asynchronously.
setMaxSubscriptionsPerTopicAsync(String, int) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set the max number of subscriptions for specified topic asynchronously.
setMaxSubscriptionsPerTopicAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Topics
setMaxTopicsPerNamespace(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set maxTopicsPerNamespace for a namespace.
setMaxTopicsPerNamespaceAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set maxTopicsPerNamespace for a namespace asynchronously.
setMaxUnackedMessagesOnConsumer(String, int) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
set max unacked messages on consumer of a topic.
setMaxUnackedMessagesOnConsumer(String, int) - Method in interface org.apache.pulsar.client.admin.Topics
setMaxUnackedMessagesOnConsumerAsync(String, int) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
set max unacked messages on consumer of a topic asynchronously.
setMaxUnackedMessagesOnConsumerAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Topics
setMaxUnackedMessagesOnSubscription(String, int) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
set max unacked messages on subscription of a topic.
setMaxUnackedMessagesOnSubscription(String, int) - Method in interface org.apache.pulsar.client.admin.Topics
setMaxUnackedMessagesOnSubscriptionAsync(String, int) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
set max unacked messages on subscription of a topic asynchronously.
setMaxUnackedMessagesOnSubscriptionAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Topics
setMaxUnackedMessagesPerConsumer(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set maxUnackedMessagesPerConsumer for a namespace.
setMaxUnackedMessagesPerConsumerAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set maxUnackedMessagesPerConsumer for a namespace asynchronously.
setMaxUnackedMessagesPerSubscription(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set maxUnackedMessagesPerSubscription for a namespace.
setMaxUnackedMessagesPerSubscriptionAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set maxUnackedMessagesPerSubscription for a namespace asynchronously.
setMessageTTL(String, int) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set message TTL for a topic.
setMessageTTL(String, int) - Method in interface org.apache.pulsar.client.admin.Topics
setNamespaceAntiAffinityGroup(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set anti-affinity group name for a namespace.
setNamespaceAntiAffinityGroupAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set anti-affinity group name for a namespace asynchronously.
setNamespaceBundleResourceQuota(String, String, ResourceQuota) - Method in interface org.apache.pulsar.client.admin.ResourceQuotas
Set resource quota for a namespace bundle.
setNamespaceBundleResourceQuotaAsync(String, String, ResourceQuota) - Method in interface org.apache.pulsar.client.admin.ResourceQuotas
Set resource quota for a namespace bundle asynchronously.
setNamespaceEntryFilters(String, EntryFilters) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set entry filters on a namespace.
setNamespaceEntryFiltersAsync(String, EntryFilters) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set entry filters on a namespace asynchronously.
setNamespaceMessageTTL(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the messages Time to Live for all the topics within a namespace.
setNamespaceMessageTTLAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the messages Time to Live for all the topics within a namespace asynchronously.
setNamespaceReplicationClusters(String, Set<String>) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the replication clusters for a namespace.
setNamespaceReplicationClustersAsync(String, Set<String>) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the replication clusters for a namespace asynchronously.
setNamespaceResourceGroup(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the ResourceGroup for a namespace.
setNamespaceResourceGroupAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the ResourceGroup for a namespace asynchronously.
setOffloadDeleteLag(String, long, TimeUnit) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the offload deletion lag for a namespace.
setOffloadDeleteLagAsync(String, long, TimeUnit) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the offload deletion lag for a namespace asynchronously.
setOffloadPolicies(String, OffloadPolicies) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the offload configuration for all the topics in a namespace.
setOffloadPolicies(String, OffloadPolicies) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
set offload policies of a topic.
setOffloadPolicies(String, OffloadPolicies) - Method in interface org.apache.pulsar.client.admin.Topics
setOffloadPoliciesAsync(String, OffloadPolicies) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the offload configuration for all the topics in a namespace asynchronously.
setOffloadPoliciesAsync(String, OffloadPolicies) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
set offload policies of a topic asynchronously.
setOffloadPoliciesAsync(String, OffloadPolicies) - Method in interface org.apache.pulsar.client.admin.Topics
setOffloadThreshold(String, long) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the offloadThreshold for a namespace.
setOffloadThresholdAsync(String, long) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the offloadThreshold for a namespace asynchronously.
setOffloadThresholdInSeconds(String, long) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the offloadThresholdInSeconds for a namespace.
setOffloadThresholdInSecondsAsync(String, long) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the offloadThresholdInSeconds for a namespace.
setPersistence(String, PersistencePolicies) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the persistence configuration for all the topics on a namespace.
setPersistence(String, PersistencePolicies) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set the configuration of persistence policies for specified topic.
setPersistence(String, PersistencePolicies) - Method in interface org.apache.pulsar.client.admin.Topics
setPersistenceAsync(String, PersistencePolicies) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the persistence configuration for all the topics on a namespace asynchronously.
setPersistenceAsync(String, PersistencePolicies) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set the configuration of persistence policies for specified topic asynchronously.
setPersistenceAsync(String, PersistencePolicies) - Method in interface org.apache.pulsar.client.admin.Topics
setPolicy(BacklogQuota.RetentionPolicy) - Method in class org.apache.pulsar.common.policies.data.impl.BacklogQuotaImpl
 
setProperties(String, Map<String, String>) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set key value pair properties for a namespace.
setPropertiesAsync(String, Map<String, String>) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set key value pair properties for a namespace asynchronously.
setProperty(String, String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set key value pair property for a namespace.
setPropertyAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set key value pair property for a namespace.
setPublishRate(String, PublishRate) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set message-publish-rate (topics under this namespace can publish this many messages per second).
setPublishRate(String, PublishRate) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set message-publish-rate (topics can publish this many messages per second).
setPublishRate(String, PublishRate) - Method in interface org.apache.pulsar.client.admin.Topics
setPublishRateAsync(String, PublishRate) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set message-publish-rate (topics under this namespace can publish this many messages per second) asynchronously.
setPublishRateAsync(String, PublishRate) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set message-publish-rate (topics can publish this many messages per second) asynchronously.
setPublishRateAsync(String, PublishRate) - Method in interface org.apache.pulsar.client.admin.Topics
setReplicatedSubscriptionStatus(String, String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
Enable or disable a replicated subscription on a topic.
setReplicatedSubscriptionStatusAsync(String, String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
Enable or disable a replicated subscription on a topic asynchronously.
setReplicationClusters(String, List<String>) - Method in interface org.apache.pulsar.client.admin.Topics
Set the replication clusters for the topic.
setReplicationClustersAsync(String, List<String>) - Method in interface org.apache.pulsar.client.admin.Topics
Set the replication clusters for the topic asynchronously.
setReplicatorDispatchRate(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set replicator-message-dispatch-rate.
setReplicatorDispatchRate(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set replicatorDispatchRate for the topic.
setReplicatorDispatchRate(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.Topics
setReplicatorDispatchRateAsync(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set replicator-message-dispatch-rate asynchronously.
setReplicatorDispatchRateAsync(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set replicatorDispatchRate for the topic asynchronously.
setReplicatorDispatchRateAsync(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.Topics
setRetention(String, RetentionPolicies) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the retention configuration for all the topics on a namespace.
setRetention(String, RetentionPolicies) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set the retention configuration on a topic.
setRetention(String, RetentionPolicies) - Method in interface org.apache.pulsar.client.admin.Topics
setRetentionAsync(String, RetentionPolicies) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the retention configuration for all the topics on a namespace asynchronously.
setRetentionAsync(String, RetentionPolicies) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set the retention configuration for all the topics on a topic asynchronously.
setRetentionAsync(String, RetentionPolicies) - Method in interface org.apache.pulsar.client.admin.Topics
setS3ManagedLedgerOffloadRoleSessionName(String) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
 
setSchemaAutoUpdateCompatibilityStrategy(String, SchemaAutoUpdateCompatibilityStrategy) - Method in interface org.apache.pulsar.client.admin.Namespaces
Deprecated.
setSchemaCompatibilityStrategy(String, SchemaCompatibilityStrategy) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the strategy used to check the a new schema provided by a producer is compatible with the current schema before it is installed.
setSchemaCompatibilityStrategy(String, SchemaCompatibilityStrategy) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set schema compatibility strategy on a topic.
setSchemaCompatibilityStrategyAsync(String, SchemaCompatibilityStrategy) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the strategy used to check the a new schema provided by a producer is compatible with the current schema before it is installed asynchronously.
setSchemaCompatibilityStrategyAsync(String, SchemaCompatibilityStrategy) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set schema compatibility strategy on a topic asynchronously.
setSchemaValidationEnforced(String, boolean) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set schema validation enforced for namespace.
setSchemaValidationEnforced(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
Get schema validation enforced for a topic.
setSchemaValidationEnforcedAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set schema validation enforced for namespace asynchronously.
setSchemaValidationEnforcedAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
Get schema validation enforced for a topic asynchronously.
setShadowTopics(String, List<String>) - Method in interface org.apache.pulsar.client.admin.Topics
Set shadow topic list for a source topic.
setShadowTopicsAsync(String, List<String>) - Method in interface org.apache.pulsar.client.admin.Topics
Set shadow topic list for a source topic asynchronously.
setSubscribeRate(String, SubscribeRate) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set namespace-subscribe-rate (topics under this namespace will limit by subscribeRate).
setSubscribeRate(String, SubscribeRate) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set topic-subscribe-rate (topic will limit by subscribeRate).
setSubscribeRate(String, SubscribeRate) - Method in interface org.apache.pulsar.client.admin.Topics
setSubscribeRateAsync(String, SubscribeRate) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set namespace-subscribe-rate (topics under this namespace will limit by subscribeRate) asynchronously.
setSubscribeRateAsync(String, SubscribeRate) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set topic-subscribe-rate (topics will limit by subscribeRate) asynchronously.
setSubscribeRateAsync(String, SubscribeRate) - Method in interface org.apache.pulsar.client.admin.Topics
setSubscriptionAuthMode(String, SubscriptionAuthMode) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the given subscription auth mode on all topics on a namespace.
setSubscriptionAuthModeAsync(String, SubscriptionAuthMode) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the given subscription auth mode on all topics on a namespace asynchronously.
setSubscriptionDispatchRate(String, String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set dispatch rate limiter for a specific subscription.
setSubscriptionDispatchRate(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set subscription-message-dispatch-rate.
setSubscriptionDispatchRate(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set subscription-message-dispatch-rate for the topic.
setSubscriptionDispatchRate(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.Topics
setSubscriptionDispatchRateAsync(String, String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
setSubscriptionDispatchRateAsync(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set subscription-message-dispatch-rate asynchronously.
setSubscriptionDispatchRateAsync(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set subscription-message-dispatch-rate for the topic asynchronously.
setSubscriptionDispatchRateAsync(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.Topics
setSubscriptionExpirationTime(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the subscription expiration time in minutes for all the topics within a namespace.
setSubscriptionExpirationTimeAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the subscription expiration time in minutes for all the topics within a namespace asynchronously.
setSubscriptionTypesEnabled(String, Set<SubscriptionType>) - Method in interface org.apache.pulsar.client.admin.Namespaces
Sets the subscriptionTypesEnabled policy for a given namespace, overriding broker settings.
setSubscriptionTypesEnabled(String, Set<SubscriptionType>) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set is enable sub types.
setSubscriptionTypesEnabled(String, Set<SubscriptionType>) - Method in interface org.apache.pulsar.client.admin.Topics
setSubscriptionTypesEnabledAsync(String, Set<SubscriptionType>) - Method in interface org.apache.pulsar.client.admin.Namespaces
Sets the subscriptionTypesEnabled policy for a given namespace, overriding broker settings.
setSubscriptionTypesEnabledAsync(String, Set<SubscriptionType>) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
Set is enable sub types asynchronously.
setSubscriptionTypesEnabledAsync(String, Set<SubscriptionType>) - Method in interface org.apache.pulsar.client.admin.Topics
setUpdateAuthData(boolean) - Method in interface org.apache.pulsar.common.functions.UpdateOptions
 
setZookeeperServers(String) - Method in class org.apache.pulsar.common.conf.InternalConfigurationData
Deprecated.
shared - Enum constant in enum class org.apache.pulsar.common.policies.data.BrokerAssignment
 
shouldFailoverToSecondary(int) - Method in class org.apache.pulsar.common.policies.AutoFailoverPolicy
 
shouldFailoverToSecondary(int) - Method in class org.apache.pulsar.common.policies.impl.MinAvailablePolicy
 
shouldFailoverToSecondary(SortedSet<BrokerStatus>) - Method in class org.apache.pulsar.common.policies.AutoFailoverPolicy
Checks to see whether the new namespace ownership should be failed over to the secondary brokers.
shouldFailoverToSecondary(SortedSet<BrokerStatus>) - Method in class org.apache.pulsar.common.policies.impl.MinAvailablePolicy
 
shutDownBrokerGracefully(int, boolean) - Method in interface org.apache.pulsar.client.admin.Brokers
Trigger the current broker to graceful-shutdown asynchronously.
singleSnapshotSystemTopicInternalStats - Variable in class org.apache.pulsar.common.policies.data.TransactionBufferInternalStats
 
sink() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
Deprecated.
Sink - Interface in org.apache.pulsar.client.admin
Deprecated.
in favor of Sinks
SINK - Enum constant in enum class org.apache.pulsar.packages.management.core.common.PackageType
 
SinkConfig - Class in org.apache.pulsar.common.io
Configuration of Pulsar Sink.
SinkConfig() - Constructor for class org.apache.pulsar.common.io.SinkConfig
 
SinkInstanceStatus() - Constructor for class org.apache.pulsar.common.policies.data.SinkStatus.SinkInstanceStatus
 
SinkInstanceStatusData() - Constructor for class org.apache.pulsar.common.policies.data.SinkStatus.SinkInstanceStatus.SinkInstanceStatusData
 
sinks - Enum constant in enum class org.apache.pulsar.common.policies.data.AuthAction
Permissions for sinks ops.
sinks() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
 
Sinks - Interface in org.apache.pulsar.client.admin
Admin interface for Sink management.
SinkStatus - Class in org.apache.pulsar.common.policies.data
Status of Pulsar Sink.
SinkStatus() - Constructor for class org.apache.pulsar.common.policies.data.SinkStatus
 
SinkStatus.SinkInstanceStatus - Class in org.apache.pulsar.common.policies.data
Status of a Sink instance.
SinkStatus.SinkInstanceStatus.SinkInstanceStatusData - Class in org.apache.pulsar.common.policies.data
Status data of a Sink instance.
size - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.LedgerInfo
 
skipAllMessages(String, String) - Method in interface org.apache.pulsar.client.admin.Topics
Skip all messages on a topic subscription.
skipAllMessagesAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Topics
Skip all messages on a topic subscription asynchronously.
skipMessages(String, String, long) - Method in interface org.apache.pulsar.client.admin.Topics
Skip messages on a topic subscription.
skipMessagesAsync(String, String, long) - Method in interface org.apache.pulsar.client.admin.Topics
Skip messages on a topic subscription asynchronously.
smallCacheSize - Variable in class org.apache.pulsar.common.stats.AllocatorStats
 
smallSubpages - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolArenaStats
 
SnapshotSystemTopicInternalStats - Class in org.apache.pulsar.common.policies.data
 
SnapshotSystemTopicInternalStats() - Constructor for class org.apache.pulsar.common.policies.data.SnapshotSystemTopicInternalStats
 
snapshotType - Variable in class org.apache.pulsar.common.policies.data.TransactionBufferInternalStats
 
snapshotType - Variable in class org.apache.pulsar.common.policies.data.TransactionBufferStats
 
source() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
Deprecated.
Source - Interface in org.apache.pulsar.client.admin
Deprecated.
in favor of Sources
SOURCE - Enum constant in enum class org.apache.pulsar.packages.management.core.common.PackageType
 
SourceConfig - Class in org.apache.pulsar.common.io
Pulsar source configuration.
SourceConfig() - Constructor for class org.apache.pulsar.common.io.SourceConfig
 
SourceInstanceStatus() - Constructor for class org.apache.pulsar.common.policies.data.SourceStatus.SourceInstanceStatus
 
SourceInstanceStatusData() - Constructor for class org.apache.pulsar.common.policies.data.SourceStatus.SourceInstanceStatus.SourceInstanceStatusData
 
sources - Enum constant in enum class org.apache.pulsar.common.policies.data.AuthAction
Permissions for sources ops.
sources() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
 
Sources - Interface in org.apache.pulsar.client.admin
Admin interface for Source management.
SourceStatus - Class in org.apache.pulsar.common.policies.data
Source status.
SourceStatus() - Constructor for class org.apache.pulsar.common.policies.data.SourceStatus
 
SourceStatus.SourceInstanceStatus - Class in org.apache.pulsar.common.policies.data
Source instance status.
SourceStatus.SourceInstanceStatus.SourceInstanceStatusData - Class in org.apache.pulsar.common.policies.data
Source instance status data.
splitNamespaceBundle(String, String, boolean, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Split namespace bundle.
splitNamespaceBundle(String, String, boolean, String, List<Long>) - Method in interface org.apache.pulsar.client.admin.Namespaces
Split namespace bundle.
splitNamespaceBundleAsync(String, String, boolean, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Split namespace bundle asynchronously.
splitNamespaceBundleAsync(String, String, boolean, String, List<Long>) - Method in interface org.apache.pulsar.client.admin.Namespaces
Split namespace bundle asynchronously.
sslProvider(String) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder
The name of the security provider used for SSL connections.
startFunction(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions
Start all function instances.
startFunction(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Functions
Start function instance.
startFunctionAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions
Start all function instances asynchronously.
startFunctionAsync(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Functions
Start function instance asynchronously.
startPosition - Variable in class org.apache.pulsar.common.policies.data.TransactionInBufferStats
The start position of this transaction in transaction buffer.
startSink(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sinks
Start all sink instances.
startSink(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sinks
Start sink instance.
startSinkAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sinks
Start all sink instances asynchronously.
startSinkAsync(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sinks
Start sink instance asynchronously.
startSource(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sources
Start all source instances.
startSource(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sources
Start source instance.
startSourceAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sources
Start all source instances asynchronously.
startSourceAsync(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sources
Start source instance asynchronously.
state - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.CursorStats
 
state - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats
The state of this ledger for writing.
state - Variable in class org.apache.pulsar.common.policies.data.TransactionBufferStats
The state of this transaction buffer.
state - Variable in class org.apache.pulsar.common.policies.data.TransactionCoordinatorStats
The state of this transaction metadataStore.
state - Variable in class org.apache.pulsar.common.policies.data.TransactionCoordinatorStatus
The state of this transaction metadataStore.
state - Variable in class org.apache.pulsar.common.policies.data.TransactionPendingAckStats
The state of this pending ack.
state - Variable in class org.apache.pulsar.common.stats.PositionInPendingAckStats
 
status - Variable in class org.apache.pulsar.client.admin.LongRunningProcessStatus
 
status - Variable in class org.apache.pulsar.common.policies.data.FunctionStatus.FunctionInstanceStatus
 
status - Variable in class org.apache.pulsar.common.policies.data.SinkStatus.SinkInstanceStatus
 
status - Variable in class org.apache.pulsar.common.policies.data.SourceStatus.SourceInstanceStatus
 
status - Variable in class org.apache.pulsar.common.policies.data.TransactionMetadata
The status of this transaction.
stopFunction(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions
Stop all function instances.
stopFunction(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Functions
Stop function instance.
stopFunctionAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions
Stop all function instances asynchronously.
stopFunctionAsync(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Functions
Stop function instance asynchronously.
stopSink(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sinks
Stop all sink instances.
stopSink(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sinks
Stop sink instance.
stopSinkAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sinks
Stop all sink instances asynchronously.
stopSinkAsync(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sinks
Stop sink instance asynchronously.
stopSource(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sources
Stop all source instances.
stopSource(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sources
Stop source instance.
stopSourceAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sources
Stop all source instances asynchronously.
stopSourceAsync(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sources
Stop source instance asynchronously.
SubscribeRate - Class in org.apache.pulsar.common.policies.data
Information about subscription rate.
SubscribeRate() - Constructor for class org.apache.pulsar.common.policies.data.SubscribeRate
 
SubscribeRate(int, int) - Constructor for class org.apache.pulsar.common.policies.data.SubscribeRate
 
subscribeThrottlingRatePerConsumer - Variable in class org.apache.pulsar.common.policies.data.SubscribeRate
 
subscription_auth_mode - Variable in class org.apache.pulsar.common.policies.data.Policies
 
subscription_expiration_time_minutes - Variable in class org.apache.pulsar.common.policies.data.Policies
 
subscription_types_enabled - Variable in class org.apache.pulsar.common.policies.data.Policies
 
subscriptionAuthentication(Map<String, Set<String>>) - Method in interface org.apache.pulsar.common.policies.data.AuthPolicies.Builder
 
SubscriptionAuthMode - Enum Class in org.apache.pulsar.common.policies.data
Subscription authorization for Pulsar policies.
subscriptionDispatchRate - Variable in class org.apache.pulsar.common.policies.data.Policies
 
subscriptionHavePendingRead - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.CursorStats
 
subscriptionHavePendingReplayRead - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.CursorStats
 
SubscriptionStats - Interface in org.apache.pulsar.common.policies.data
Statistics about subscription.
substract(ResourceQuota) - Method in class org.apache.pulsar.common.policies.data.ResourceQuota
Substract quota.
success() - Static method in class org.apache.pulsar.common.policies.data.ValidateResult
 
SUCCESS - Enum constant in enum class org.apache.pulsar.client.admin.LongRunningProcessStatus.Status
 

T

TenantInfo - Interface in org.apache.pulsar.common.policies.data
 
TenantInfo.Builder - Interface in org.apache.pulsar.common.policies.data
 
tenants() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
 
Tenants - Interface in org.apache.pulsar.client.admin
Admin interface for tenants management.
terminatePartitionedTopic(String) - Method in interface org.apache.pulsar.client.admin.Topics
Terminate the partitioned topic and prevent any more messages being published on it.
terminatePartitionedTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
Terminate the partitioned topic and prevent any more messages being published on it.
terminateTopic(String) - Method in interface org.apache.pulsar.client.admin.Topics
Terminate the topic and prevent any more messages being published on it.
terminateTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
Terminate the topic and prevent any more messages being published on it.
testCompatibility(String, PostSchemaPayload) - Method in interface org.apache.pulsar.client.admin.Schemas
Judge schema compatibility topic.
testCompatibility(String, SchemaInfo) - Method in interface org.apache.pulsar.client.admin.Schemas
Judge schema compatibility topic.
testCompatibilityAsync(String, PostSchemaPayload) - Method in interface org.apache.pulsar.client.admin.Schemas
Judge schema compatibility topic asynchronously.
testCompatibilityAsync(String, SchemaInfo) - Method in interface org.apache.pulsar.client.admin.Schemas
Judge schema compatibility topic asynchronously.
tickTime(long) - Method in interface org.apache.pulsar.common.policies.data.DelayedDeliveryPolicies.Builder
 
tickTime(long) - Method in class org.apache.pulsar.common.policies.data.impl.DelayedDeliveryPoliciesImpl.DelayedDeliveryPoliciesImplBuilder
 
TIERED_STORAGE_FIRST - Enum constant in enum class org.apache.pulsar.common.policies.data.OffloadedReadPriority
For offloaded messages, readers will try to read from offloaded storage first, even they are still exist in bookkeeper.
timeoutAt - Variable in class org.apache.pulsar.common.policies.data.TransactionMetadata
The timeout of this transaction.
TimeoutException(Throwable) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.TimeoutException
 
tlsAllowInsecureConnection(boolean) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
 
tlsCertificateFilePath(String) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder
Set the path to the TLS certificate file.
tlsCiphers(Set<String>) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder
A list of cipher suites.
tlsKeyFilePath(String) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder
Set the path to the TLS key file.
tlsKeyStorePassword(String) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder
The store password for the key store file.
tlsKeyStorePath(String) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder
The location of the key store file.
tlsKeyStoreType(String) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder
The file format of the key store file.
tlsProtocols(Set<String>) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder
The SSL protocol used to generate the SSLContext.
tlsTrustCertsFilePath(String) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder
Set the path to the trusted TLS certificate file.
tlsTrustStorePassword(String) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder
The store password for the key store file.
tlsTrustStorePath(String) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder
The location of the trust store file.
tlsTrustStoreType(String) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder
The file format of the trust store file.
topicAuthentication(Map<String, Map<String, Set<AuthAction>>>) - Method in interface org.apache.pulsar.common.policies.data.AuthPolicies.Builder
 
topicDispatchRate - Variable in class org.apache.pulsar.common.policies.data.Policies
 
TopicDomain - Enum Class in org.apache.pulsar.common.naming
Enumeration showing if a topic is persistent.
TopicHashPositions - Class in org.apache.pulsar.common.policies.data
 
TopicHashPositions() - Constructor for class org.apache.pulsar.common.policies.data.TopicHashPositions
 
topicPolicies() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
Get the topic policies management object.
topicPolicies(boolean) - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
Get the local/global topic policies management object.
TopicPolicies - Interface in org.apache.pulsar.client.admin
Admin interface for topic policies management.
topics - Variable in class org.apache.pulsar.policies.data.loadbalancer.NamespaceBundleStats
 
topics() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
 
Topics - Interface in org.apache.pulsar.client.admin
Admin interface for Topics management.
Topics.QueryParam - Enum Class in org.apache.pulsar.client.admin
 
TopicStats - Interface in org.apache.pulsar.common.policies.data
Statistics for a Pulsar topic.
topicType(String) - Method in interface org.apache.pulsar.common.policies.data.AutoTopicCreationOverride.Builder
 
topicType(String) - Method in class org.apache.pulsar.common.policies.data.impl.AutoTopicCreationOverrideImpl.AutoTopicCreationOverrideImplBuilder
 
TopicType - Enum Class in org.apache.pulsar.common.policies.data
Topic types -- partitioned or non-partitioned.
TopicVersion - Enum Class in org.apache.pulsar.common.naming
 
toString() - Method in enum class org.apache.pulsar.common.naming.TopicDomain
 
toString() - Method in class org.apache.pulsar.common.policies.data.NamespaceOwnershipStatus
 
toString() - Method in enum class org.apache.pulsar.common.policies.data.OffloadedReadPriority
 
toString() - Method in class org.apache.pulsar.common.policies.data.RetentionPolicies
 
toString() - Method in enum class org.apache.pulsar.common.policies.data.TopicType
 
toString() - Method in class org.apache.pulsar.common.stats.Metrics
 
toString() - Method in enum class org.apache.pulsar.packages.management.core.common.PackageType
 
totalAbortedTransactions - Variable in class org.apache.pulsar.common.policies.data.TransactionBufferStats
 
totalNonContiguousDeletedMessagesRange - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.CursorStats
 
totalSize - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats
The total storage size of all messages (in bytes).
TransactionBufferInternalStats - Class in org.apache.pulsar.common.policies.data
 
TransactionBufferInternalStats() - Constructor for class org.apache.pulsar.common.policies.data.TransactionBufferInternalStats
 
TransactionBufferStats - Class in org.apache.pulsar.common.policies.data
 
TransactionBufferStats() - Constructor for class org.apache.pulsar.common.policies.data.TransactionBufferStats
 
TransactionCoordinatorInfo - Class in org.apache.pulsar.common.policies.data
Transaction coordinator information.
TransactionCoordinatorInfo() - Constructor for class org.apache.pulsar.common.policies.data.TransactionCoordinatorInfo
 
TransactionCoordinatorInternalStats - Class in org.apache.pulsar.common.policies.data
Transaction coordinator internal stats.
TransactionCoordinatorInternalStats() - Constructor for class org.apache.pulsar.common.policies.data.TransactionCoordinatorInternalStats
 
TransactionCoordinatorStats - Class in org.apache.pulsar.common.policies.data
Transaction coordinator stats.
TransactionCoordinatorStats() - Constructor for class org.apache.pulsar.common.policies.data.TransactionCoordinatorStats
 
TransactionCoordinatorStatus - Class in org.apache.pulsar.common.policies.data
Transaction coordinator status.
TransactionCoordinatorStatus() - Constructor for class org.apache.pulsar.common.policies.data.TransactionCoordinatorStatus
 
TransactionInBufferStats - Class in org.apache.pulsar.common.policies.data
 
TransactionInBufferStats() - Constructor for class org.apache.pulsar.common.policies.data.TransactionInBufferStats
 
TransactionInPendingAckStats - Class in org.apache.pulsar.common.policies.data
 
TransactionInPendingAckStats() - Constructor for class org.apache.pulsar.common.policies.data.TransactionInPendingAckStats
 
transactionLogStats - Variable in class org.apache.pulsar.common.policies.data.TransactionCoordinatorInternalStats
The transaction coordinator log stats.
TransactionLogStats - Class in org.apache.pulsar.common.policies.data
Transaction log stats.
TransactionLogStats() - Constructor for class org.apache.pulsar.common.policies.data.TransactionLogStats
 
TransactionMetadata - Class in org.apache.pulsar.common.policies.data
 
TransactionMetadata() - Constructor for class org.apache.pulsar.common.policies.data.TransactionMetadata
 
TransactionPendingAckInternalStats - Class in org.apache.pulsar.common.policies.data
Transaction pending ack internal stats.
TransactionPendingAckInternalStats() - Constructor for class org.apache.pulsar.common.policies.data.TransactionPendingAckInternalStats
 
TransactionPendingAckStats - Class in org.apache.pulsar.common.policies.data
 
TransactionPendingAckStats() - Constructor for class org.apache.pulsar.common.policies.data.TransactionPendingAckStats
 
transactions() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
 
Transactions - Interface in org.apache.pulsar.client.admin
 
triggerCompaction(String) - Method in interface org.apache.pulsar.client.admin.Topics
Trigger compaction to run for a topic.
triggerCompactionAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
Trigger compaction to run for a topic asynchronously.
triggerFunction(String, String, String, String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions
Triggers the function by writing to the input topic.
triggerFunctionAsync(String, String, String, String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions
Triggers the function by writing to the input topic asynchronously.
triggerOffload(String, MessageId) - Method in interface org.apache.pulsar.client.admin.Topics
Trigger offloading messages in topic to longterm storage.
triggerOffloadAsync(String, MessageId) - Method in interface org.apache.pulsar.client.admin.Topics
Trigger offloading messages in topic to longterm storage asynchronously.
trimTopic(String) - Method in interface org.apache.pulsar.client.admin.Topics
Trigger topic trimming.
trimTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
Trigger topic trimming asynchronously.
truncate(String) - Method in interface org.apache.pulsar.client.admin.Topics
Truncate a topic.
truncateAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
Truncate a topic asynchronously.
txnId - Variable in class org.apache.pulsar.common.policies.data.TransactionMetadata
The txnId of this transaction.

U

UNDEFINED - Enum constant in enum class org.apache.pulsar.common.policies.data.SchemaCompatibilityStrategy
Undefined.
underReplicated - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.LedgerInfo
 
unload(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Unload a namespace from the current serving broker.
unload(String) - Method in interface org.apache.pulsar.client.admin.NonPersistentTopics
Deprecated.
Unload a topic.
unload(String) - Method in interface org.apache.pulsar.client.admin.Topics
Unload a topic.
unloadAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Unload a namespace from the current serving broker asynchronously.
unloadAsync(String) - Method in interface org.apache.pulsar.client.admin.NonPersistentTopics
Deprecated.
Unload a topic asynchronously.
unloadAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
Unload a topic asynchronously.
unloadNamespaceBundle(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Unload namespace bundle.
unloadNamespaceBundle(String, String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Unload namespace bundle and assign the bundle to specified broker.
unloadNamespaceBundleAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Unload namespace bundle asynchronously.
unloadNamespaceBundleAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Unload namespace bundle asynchronously.
unsealedAbortTxnIDSize - Variable in class org.apache.pulsar.common.policies.data.SegmentsStats
 
unsubscribeNamespace(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Unsubscribe the given subscription on all topics on a namespace.
unsubscribeNamespaceAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Unsubscribe the given subscription on all topics on a namespace asynchronously.
unsubscribeNamespaceBundle(String, String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Unsubscribe the given subscription on all topics on a namespace bundle.
unsubscribeNamespaceBundleAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Unsubscribe the given subscription on all topics on a namespace bundle asynchronously.
updateBookie(String, String, BookieInfo) - Method in class org.apache.pulsar.common.policies.data.BookiesRackConfiguration
 
updateBookieRackInfo(String, String, BookieInfo) - Method in interface org.apache.pulsar.client.admin.Bookies
Updates the rack placement information for a specific bookie in the cluster.
updateBookieRackInfoAsync(String, String, BookieInfo) - Method in interface org.apache.pulsar.client.admin.Bookies
Updates the rack placement information for a specific bookie in the cluster asynchronously.
updateCluster(String, ClusterData) - Method in interface org.apache.pulsar.client.admin.Clusters
Update the configuration for a cluster.
updateClusterAsync(String, ClusterData) - Method in interface org.apache.pulsar.client.admin.Clusters
Update the configuration for a cluster asynchronously.
updateClusterMigration(String, boolean, ClusterData.ClusterUrl) - Method in interface org.apache.pulsar.client.admin.Clusters
Update the configuration for a cluster migration.
updateClusterMigrationAsync(String, boolean, ClusterData.ClusterUrl) - Method in interface org.apache.pulsar.client.admin.Clusters
Update the configuration for a cluster migration asynchronously.
updateDynamicConfiguration(String, String) - Method in interface org.apache.pulsar.client.admin.Brokers
Update a dynamic configuration value into ZooKeeper.
updateDynamicConfigurationAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Brokers
Update a dynamic configuration value into ZooKeeper asynchronously.
updateFailureDomain(String, String, FailureDomain) - Method in interface org.apache.pulsar.client.admin.Clusters
Update a domain into cluster.
updateFailureDomainAsync(String, String, FailureDomain) - Method in interface org.apache.pulsar.client.admin.Clusters
Update a domain into cluster asynchronously.
updateFunction(FunctionConfig, String) - Method in interface org.apache.pulsar.client.admin.Functions
Update the configuration for a function.
updateFunction(FunctionConfig, String, UpdateOptions) - Method in interface org.apache.pulsar.client.admin.Functions
Update the configuration for a function.
updateFunctionAsync(FunctionConfig, String) - Method in interface org.apache.pulsar.client.admin.Functions
Update the configuration for a function asynchronously.
updateFunctionAsync(FunctionConfig, String, UpdateOptions) - Method in interface org.apache.pulsar.client.admin.Functions
Update the configuration for a function asynchronously.
updateFunctionWithUrl(FunctionConfig, String) - Method in interface org.apache.pulsar.client.admin.Functions
Update the configuration for a function.
updateFunctionWithUrl(FunctionConfig, String, UpdateOptions) - Method in interface org.apache.pulsar.client.admin.Functions
Update the configuration for a function.
updateFunctionWithUrlAsync(FunctionConfig, String) - Method in interface org.apache.pulsar.client.admin.Functions
Update the configuration for a function asynchronously.
updateFunctionWithUrlAsync(FunctionConfig, String, UpdateOptions) - Method in interface org.apache.pulsar.client.admin.Functions
Update the configuration for a function asynchronously.
updateMetadata(String, PackageMetadata) - Method in interface org.apache.pulsar.client.admin.Packages
Update a package metadata information.
updateMetadataAsync(String, PackageMetadata) - Method in interface org.apache.pulsar.client.admin.Packages
Update a package metadata information asynchronously.
updateNamespaceIsolationPolicy(String, String, NamespaceIsolationData) - Method in interface org.apache.pulsar.client.admin.Clusters
Update a namespace isolation policy for a cluster.
updateNamespaceIsolationPolicyAsync(String, String, NamespaceIsolationData) - Method in interface org.apache.pulsar.client.admin.Clusters
Update a namespace isolation policy for a cluster asynchronously.
UpdateOptions - Interface in org.apache.pulsar.common.functions
 
updatePartitionedTopic(String, int) - Method in interface org.apache.pulsar.client.admin.Topics
Update number of partitions of a partitioned topic.
updatePartitionedTopic(String, int, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
Update number of partitions of a partitioned topic.
updatePartitionedTopic(String, int, boolean, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
Update number of partitions of a partitioned topic.
updatePartitionedTopicAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Topics
Update number of partitions of a partitioned topic asynchronously.
updatePartitionedTopicAsync(String, int, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
Update number of partitions of a partitioned topic asynchronously.
updatePartitionedTopicAsync(String, int, boolean, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
Update number of partitions of a partitioned topic asynchronously.
updatePeerClusterNames(String, LinkedHashSet<String>) - Method in interface org.apache.pulsar.client.admin.Clusters
Update peer cluster names.
updatePeerClusterNamesAsync(String, LinkedHashSet<String>) - Method in interface org.apache.pulsar.client.admin.Clusters
Update peer cluster names asynchronously.
updateProperties(String, Map<String, String>) - Method in interface org.apache.pulsar.client.admin.Topics
Update Topic Properties on a topic.
updatePropertiesAsync(String, Map<String, String>) - Method in interface org.apache.pulsar.client.admin.Topics
Update Topic Properties on a topic.
updateProperty(String, TenantInfo) - Method in interface org.apache.pulsar.client.admin.Properties
Deprecated.
Update the admins for a property.
updateResourceGroup(String, ResourceGroup) - Method in interface org.apache.pulsar.client.admin.ResourceGroups
Update the configuration for a ResourceGroup.
updateResourceGroupAsync(String, ResourceGroup) - Method in interface org.apache.pulsar.client.admin.ResourceGroups
Update the configuration for a ResourceGroup.
updateSink(SinkConfig, String) - Method in interface org.apache.pulsar.client.admin.Sinks
Update the configuration for a sink.
updateSink(SinkConfig, String, UpdateOptions) - Method in interface org.apache.pulsar.client.admin.Sinks
Update the configuration for a sink.
updateSinkAsync(SinkConfig, String) - Method in interface org.apache.pulsar.client.admin.Sinks
Update the configuration for a sink asynchronously.
updateSinkAsync(SinkConfig, String, UpdateOptions) - Method in interface org.apache.pulsar.client.admin.Sinks
Update the configuration for a sink asynchronously.
updateSinkWithUrl(SinkConfig, String) - Method in interface org.apache.pulsar.client.admin.Sinks
Update the configuration for a sink.
updateSinkWithUrl(SinkConfig, String, UpdateOptions) - Method in interface org.apache.pulsar.client.admin.Sinks
Update the configuration for a sink.
updateSinkWithUrlAsync(SinkConfig, String) - Method in interface org.apache.pulsar.client.admin.Sinks
Update the configuration for a sink asynchronously.
updateSinkWithUrlAsync(SinkConfig, String, UpdateOptions) - Method in interface org.apache.pulsar.client.admin.Sinks
Update the configuration for a sink asynchronously.
updateSource(SourceConfig, String) - Method in interface org.apache.pulsar.client.admin.Sources
Update the configuration for a source.
updateSource(SourceConfig, String, UpdateOptions) - Method in interface org.apache.pulsar.client.admin.Sources
Update the configuration for a source.
updateSourceAsync(SourceConfig, String) - Method in interface org.apache.pulsar.client.admin.Sources
Update the configuration for a source asynchronously.
updateSourceAsync(SourceConfig, String, UpdateOptions) - Method in interface org.apache.pulsar.client.admin.Sources
Update the configuration for a source asynchronously.
updateSourceWithUrl(SourceConfig, String) - Method in interface org.apache.pulsar.client.admin.Sources
Update the configuration for a source.
updateSourceWithUrl(SourceConfig, String, UpdateOptions) - Method in interface org.apache.pulsar.client.admin.Sources
Update the configuration for a source.
updateSourceWithUrlAsync(SourceConfig, String) - Method in interface org.apache.pulsar.client.admin.Sources
Update the configuration for a source asynchronously.
updateSourceWithUrlAsync(SourceConfig, String, UpdateOptions) - Method in interface org.apache.pulsar.client.admin.Sources
Update the configuration for a source asynchronously.
updateSubscriptionProperties(String, String, Map<String, String>) - Method in interface org.apache.pulsar.client.admin.Topics
Update Subscription Properties on a topic subscription.
updateSubscriptionPropertiesAsync(String, String, Map<String, String>) - Method in interface org.apache.pulsar.client.admin.Topics
Update Subscription Properties on a topic subscription.
updateTenant(String, TenantInfo) - Method in interface org.apache.pulsar.client.admin.Tenants
Update the admins for a tenant.
updateTenantAsync(String, TenantInfo) - Method in interface org.apache.pulsar.client.admin.Tenants
Update the admins for a tenant asynchronously.
upload(PackageMetadata, String, String) - Method in interface org.apache.pulsar.client.admin.Packages
Upload a package to the package management service.
uploadAsync(PackageMetadata, String, String) - Method in interface org.apache.pulsar.client.admin.Packages
Upload a package to the package management service asynchronously.
uploadFunction(String, String) - Method in interface org.apache.pulsar.client.admin.Functions
Upload Data.
uploadFunctionAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Functions
Upload Data asynchronously.
usage - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolChunkStats
 
usage - Variable in class org.apache.pulsar.policies.data.loadbalancer.ResourceUsage
 
usage_threshold - Variable in class org.apache.pulsar.common.policies.impl.MinAvailablePolicy
 
useKeyStoreTls(boolean) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder
If Tls is enabled, whether use KeyStore type as tls configuration parameter.

V

V1 - Enum constant in enum class org.apache.pulsar.common.naming.TopicVersion
 
V2 - Enum constant in enum class org.apache.pulsar.common.naming.TopicVersion
 
validate() - Method in interface org.apache.pulsar.common.policies.data.AutoFailoverPolicyData
 
validate() - Method in interface org.apache.pulsar.common.policies.data.NamespaceIsolationData
 
validateOverride(AutoTopicCreationOverride) - Static method in class org.apache.pulsar.common.policies.data.impl.AutoTopicCreationOverrideImpl
 
ValidateResult - Class in org.apache.pulsar.common.policies.data
 
value - Variable in enum class org.apache.pulsar.client.admin.Topics.QueryParam
 
value() - Method in enum class org.apache.pulsar.common.naming.TopicDomain
 
value() - Method in enum class org.apache.pulsar.packages.management.core.common.PackageType
 
valueOf(int) - Static method in enum class org.apache.pulsar.client.admin.Mode
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.client.admin.LongRunningProcessStatus.Status
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.client.admin.Mode
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.client.admin.Topics.QueryParam
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.common.functions.FunctionConfig.ProcessingGuarantees
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.common.functions.FunctionConfig.Runtime
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.common.functions.WindowConfig.ProcessingGuarantees
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.common.naming.TopicDomain
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.common.naming.TopicVersion
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.common.policies.data.AuthAction
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.common.policies.data.AutoFailoverPolicyType
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.common.policies.data.BacklogQuota.BacklogQuotaType
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.common.policies.data.BacklogQuota.RetentionPolicy
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.common.policies.data.BrokerAssignment
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.common.policies.data.InactiveTopicDeleteMode
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.common.policies.data.OffloadedReadPriority
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.common.policies.data.Policies.BundleType
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.common.policies.data.SchemaAutoUpdateCompatibilityStrategy
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.common.policies.data.SchemaCompatibilityStrategy
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.common.policies.data.SubscriptionAuthMode
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.common.policies.data.TopicType
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.common.stats.PositionInPendingAckStats.State
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.packages.management.core.common.PackageType
Returns the enum constant of this class with the specified name.
values() - Static method in enum class org.apache.pulsar.client.admin.LongRunningProcessStatus.Status
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.client.admin.Mode
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.client.admin.Topics.QueryParam
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.common.functions.FunctionConfig.ProcessingGuarantees
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.common.functions.FunctionConfig.Runtime
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.common.functions.WindowConfig.ProcessingGuarantees
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.common.naming.TopicDomain
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.common.naming.TopicVersion
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.common.policies.data.AuthAction
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.common.policies.data.AutoFailoverPolicyType
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.common.policies.data.BacklogQuota.BacklogQuotaType
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.common.policies.data.BacklogQuota.RetentionPolicy
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.common.policies.data.BrokerAssignment
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.common.policies.data.InactiveTopicDeleteMode
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.common.policies.data.OffloadedReadPriority
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.common.policies.data.Policies.BundleType
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.common.policies.data.SchemaAutoUpdateCompatibilityStrategy
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.common.policies.data.SchemaCompatibilityStrategy
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.common.policies.data.SubscriptionAuthMode
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.common.policies.data.TopicType
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.common.stats.PositionInPendingAckStats.State
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.packages.management.core.common.PackageType
Returns an array containing the constants of this enum class, in the order they are declared.

W

waitingCursorsCount - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats
The number of cursors that are "caught up" and waiting for a new message to be published.
waitingReadOp - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.CursorStats
 
WINDOW_CONFIG_KEY - Static variable in class org.apache.pulsar.common.functions.WindowConfig
 
WindowConfig - Class in org.apache.pulsar.common.functions
Configuration of a windowing function.
WindowConfig() - Constructor for class org.apache.pulsar.common.functions.WindowConfig
 
WindowConfig.ProcessingGuarantees - Enum Class in org.apache.pulsar.common.functions
This is a semantic option that windows can provide, forcing the semantics of the FunctionConfig.ProcessingGuarantees to be equal to MANUAL, and then letting the windows function handle the semantic timing by itself.
worker() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
 
Worker - Interface in org.apache.pulsar.client.admin
Admin interface for worker stats management.
WorkerFunctionInstanceStats - Class in org.apache.pulsar.common.policies.data
Data class holding statistics about a function.
WorkerFunctionInstanceStats() - Constructor for class org.apache.pulsar.common.policies.data.WorkerFunctionInstanceStats
 
workerId - Variable in class org.apache.pulsar.common.policies.data.FunctionStatus.FunctionInstanceStatus.FunctionInstanceStatusData
 
workerId - Variable in class org.apache.pulsar.common.policies.data.SinkStatus.SinkInstanceStatus.SinkInstanceStatusData
 
workerId - Variable in class org.apache.pulsar.common.policies.data.SourceStatus.SourceInstanceStatus.SourceInstanceStatusData
 
WorkerInfo - Class in org.apache.pulsar.common.functions
Worker information.
WorkerInfo() - Constructor for class org.apache.pulsar.common.functions.WorkerInfo
 
wrap(PulsarAdminException) - Static method in exception org.apache.pulsar.client.admin.PulsarAdminException
Clone the exception and grab the current stacktrace.
A B C D E F G H I J L M N O P R S T U V W 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form