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

Deprecated.

Use TopicPolicies.removeDeduplicationStatus(String) instead.

disableDeduplicationAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics

Deprecated.

Use TopicPolicies.removeDeduplicationStatusAsync(String) instead.

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

Deprecated.

Use TopicPolicies.setDeduplicationStatus(String, boolean) instead.

enableDeduplicationAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics

Deprecated.

Use TopicPolicies.setDeduplicationStatusAsync(String, boolean) instead.

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

Deprecated.

Use TopicPolicies.getBacklogQuotaMap(String) instead.

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

Deprecated.

Use TopicPolicies.getBacklogQuotaMap(String, boolean) instead.

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

Deprecated.

Use TopicPolicies.getCompactionThreshold(String) instead.

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

Deprecated.

Use TopicPolicies.getCompactionThreshold(String, boolean) instead.

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

Deprecated.

Use TopicPolicies.getCompactionThresholdAsync(String) instead.

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

Deprecated.

Use TopicPolicies.getCompactionThreshold(String, boolean) instead.

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

Deprecated.

Use TopicPolicies.getDeduplicationStatus(String) instead.

getDeduplicationEnabledAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics

Deprecated.

Use TopicPolicies.getDeduplicationStatusAsync(String) instead.

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

Deprecated.

Use TopicPolicies.getDeduplicationSnapshotInterval(String) instead.

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

Deprecated.

Use TopicPolicies.getDeduplicationSnapshotIntervalAsync(String) instead.

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

Deprecated.

Use TopicPolicies.getDeduplicationStatus(String) instead.

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

Deprecated.

Use TopicPolicies.getDeduplicationStatus(String, boolean) instead.

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

Deprecated.

Use TopicPolicies.getDeduplicationStatusAsync(String) instead.

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

Deprecated.

Use TopicPolicies.getDeduplicationStatusAsync(String, boolean) instead.

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

Deprecated.

Use TopicPolicies.getDelayedDeliveryPolicy(String) instead.

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

Deprecated.

Use TopicPolicies.getDelayedDeliveryPolicy(String, boolean) instead.

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

Deprecated.

Use TopicPolicies.getDelayedDeliveryPolicyAsync(String) instead.

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

Deprecated.

Use TopicPolicies.getDelayedDeliveryPolicyAsync(String, boolean) instead.

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.

Use TopicPolicies.getDispatchRate(String) instead.

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

Deprecated.

Use TopicPolicies.getDispatchRate(String, boolean) instead.

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

Deprecated.

Use TopicPolicies.getDispatchRateAsync(String) instead.

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

Deprecated.

Use TopicPolicies.getDispatchRateAsync(String, boolean) instead.

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

Deprecated.

Use TopicPolicies.getInactiveTopicPolicies(String) instead.

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

Deprecated.

Use TopicPolicies.getInactiveTopicPolicies(String, boolean) instead.

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

Deprecated.

Use TopicPolicies.getInactiveTopicPoliciesAsync(String) instead.

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

Deprecated.

Use TopicPolicies.getInactiveTopicPoliciesAsync(String, boolean) instead.

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

Deprecated.

use Topics.getList(String, TopicDomain, ListTopicsOptions) instead.

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

Deprecated.

use Topics.getListAsync(String, TopicDomain, ListTopicsOptions) instead.

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.

Use TopicPolicies.getMaxConsumers(String) instead.

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

Deprecated.

Use TopicPolicies.getMaxConsumers(String, boolean) instead.

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

Deprecated.

Use TopicPolicies.getMaxConsumersAsync(String) instead.

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

Deprecated.

Use TopicPolicies.getMaxConsumersAsync(String, boolean) instead.

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

Deprecated.

Use TopicPolicies.getMaxConsumersPerSubscription(String) instead.

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

Deprecated.

Use TopicPolicies.getMaxConsumersPerSubscriptionAsync(String) instead.

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.

Use TopicPolicies.getMaxMessageSize(String) instead.

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

Deprecated.

Use TopicPolicies.getMaxMessageSizeAsync(String) instead.

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.

Use TopicPolicies.getMaxProducers(String) instead.

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

Deprecated.

Use TopicPolicies.getMaxProducers(String, boolean) instead.

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

Deprecated.

Use TopicPolicies.getMaxProducersAsync(String) instead.

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

Deprecated.

Use TopicPolicies.getMaxProducersAsync(String, boolean) instead.

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

Deprecated.

Use TopicPolicies.getMaxSubscriptionsPerTopic(String) instead.

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

Deprecated.

Use TopicPolicies.getMaxSubscriptionsPerTopicAsync(String) instead.

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

Deprecated.

Use TopicPolicies.getMaxUnackedMessagesOnConsumer(String) instead.

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

Deprecated.

Use TopicPolicies.getMaxUnackedMessagesOnConsumer(String, boolean) instead.

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

Deprecated.

Use TopicPolicies.getMaxUnackedMessagesOnConsumerAsync(String) instead.

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

Deprecated.

Use TopicPolicies.getMaxUnackedMessagesOnConsumerAsync(String, boolean) instead.

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

Deprecated.

Use TopicPolicies.getMaxUnackedMessagesOnSubscription(String) instead.

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

Deprecated.

Use TopicPolicies.getMaxUnackedMessagesOnSubscriptionAsync(String, boolean) instead.

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

Deprecated.

Use TopicPolicies.getMaxUnackedMessagesOnSubscriptionAsync(String) instead.

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

Deprecated.

Use TopicPolicies.getMaxUnackedMessagesOnSubscriptionAsync(String, boolean) instead.

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.

Use TopicPolicies.getMessageTTL(String) instead.

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

Deprecated.

Use TopicPolicies.getMessageTTL(String, boolean) instead.

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

Deprecated.

Use TopicPolicies.getOffloadPolicies(String) instead.

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

Deprecated.

Use TopicPolicies.getOffloadPolicies(String, boolean) instead.

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

Deprecated.

Use TopicPolicies.getOffloadPoliciesAsync(String) instead.

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

Deprecated.

Use TopicPolicies.getOffloadPoliciesAsync(String, boolean) instead.

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.

Use TopicPolicies.getPersistence(String) instead.

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

Deprecated.

Use TopicPolicies.getPersistence(String, boolean) instead.

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

Deprecated.

Use TopicPolicies.getPersistenceAsync(String) instead.

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

Deprecated.

Use TopicPolicies.getPersistenceAsync(String, boolean) instead.

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.

Use TopicPolicies.getPublishRate(String) instead.

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

Deprecated.

Use TopicPolicies.getPublishRateAsync(String) instead.

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

Deprecated.

Use TopicPolicies.getReplicatorDispatchRate(String) instead.

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

Deprecated.

Use TopicPolicies.getReplicatorDispatchRate(String, boolean) instead.

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

Deprecated.

Use TopicPolicies.getReplicatorDispatchRateAsync(String) instead.

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

Deprecated.

Use TopicPolicies.getReplicatorDispatchRateAsync(String, boolean) instead.

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.

Use TopicPolicies.getRetention(String) instead.

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

Deprecated.

Use TopicPolicies.getRetention(String, boolean) instead.

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.

Use TopicPolicies.getRetentionAsync(String) instead.

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

Deprecated.

Use TopicPolicies.getRetentionAsync(String, boolean) instead.

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.

Use TopicPolicies.getSubscribeRate(String) instead.

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

Deprecated.

Use TopicPolicies.getSubscribeRate(String, boolean) instead.

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

Deprecated.

Use TopicPolicies.getSubscribeRateAsync(String) instead.

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

Deprecated.

Use TopicPolicies.getSubscribeRateAsync(String, boolean) instead.

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

Deprecated.

Use TopicPolicies.getSubscriptionDispatchRate(String) instead.

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

Deprecated.

Use TopicPolicies.getSubscriptionDispatchRate(String, boolean) instead.

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

Deprecated.

Use TopicPolicies.getSubscriptionDispatchRateAsync(String) instead.

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

Deprecated.

Use TopicPolicies.getSubscriptionDispatchRateAsync(String, boolean) instead.

getSubscriptionDispatchRateAsync(String, String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies

Async version of TopicPolicies.getSubscriptionDispatchRate(String, String).

getSubscriptionDispatchRateAsync(String, String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies

Async version of TopicPolicies.getSubscriptionDispatchRate(String, String, boolean).

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

Deprecated.

Use TopicPolicies.getSubscriptionTypesEnabled(String) instead.

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

Deprecated.

Use TopicPolicies.getSubscriptionTypesEnabledAsync(String) instead.

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.

see Tenants from PulsarAdmin.tenants()

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

Deprecated.

Use TopicPolicies.removeBacklogQuota(String) instead.

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

Deprecated.

Use TopicPolicies.removeBacklogQuota(String, BacklogQuota.BacklogQuotaType) instead.

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

Deprecated.

Use TopicPolicies.removeCompactionThreshold(String) instead.

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

Deprecated.

Use TopicPolicies.removeCompactionThresholdAsync(String) instead.

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

Deprecated.

Use TopicPolicies.removeDeduplicationSnapshotInterval(String) instead.

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

Deprecated.

Use TopicPolicies.removeDeduplicationSnapshotIntervalAsync(String) instead.

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

Deprecated.

Use TopicPolicies.removeDeduplicationStatus(String) instead.

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

Deprecated.

Use TopicPolicies.removeDeduplicationStatusAsync(String) instead.

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

Deprecated.

Use TopicPolicies.removeDelayedDeliveryPolicy(String) instead.

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

Deprecated.

Use TopicPolicies.removeDelayedDeliveryPolicyAsync(String) instead.

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

Deprecated.

Use TopicPolicies.removeDispatchRate(String) instead.

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

Deprecated.

Use TopicPolicies.removeDispatchRateAsync(String) instead.

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

Deprecated.

Use TopicPolicies.removeInactiveTopicPolicies(String) instead.

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

Deprecated.

Use TopicPolicies.removeInactiveTopicPoliciesAsync(String) instead.

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

Deprecated.

Use TopicPolicies.removeMaxConsumers(String) instead.

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

Deprecated.

Use TopicPolicies.removeMaxConsumersAsync(String) instead.

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

Deprecated.

Use TopicPolicies.removeMaxConsumersPerSubscription(String) instead.

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

Deprecated.

Use TopicPolicies.removeMaxConsumersPerSubscriptionAsync(String) instead.

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

Deprecated.

Use TopicPolicies.removeMaxMessageSize(String) instead.

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

Deprecated.

Use TopicPolicies.removeMaxMessageSizeAsync(String) instead.

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

Deprecated.

Use TopicPolicies.removeMaxProducers(String) instead.

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

Deprecated.

Use TopicPolicies.removeMaxProducersAsync(String) instead.

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

Deprecated.

Use TopicPolicies.removeMaxSubscriptionsPerTopic(String) instead.

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

Deprecated.

Use TopicPolicies.removeMaxSubscriptionsPerTopicAsync(String) instead.

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

Deprecated.

Use TopicPolicies.removeMaxUnackedMessagesOnConsumer(String) instead.

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

Deprecated.

Use TopicPolicies.removeMaxUnackedMessagesOnConsumerAsync(String) instead.

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

Deprecated.

Use TopicPolicies.removeMaxUnackedMessagesOnSubscription(String) instead.

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

Deprecated.

Use TopicPolicies.removeMaxUnackedMessagesOnSubscriptionAsync(String) instead.

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.

Use TopicPolicies.removeMessageTTL(String) instead.

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

Deprecated.

Use TopicPolicies.removeOffloadPolicies(String) instead.

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

Deprecated.

Use TopicPolicies.removeOffloadPoliciesAsync(String) instead.

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.

Use TopicPolicies.removePersistence(String) instead.

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

Deprecated.

Use TopicPolicies.removePersistenceAsync(String) instead.

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.

Use TopicPolicies.removePublishRate(String) instead.

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

Deprecated.

Use TopicPolicies.removePublishRateAsync(String) instead.

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

Deprecated.

Use TopicPolicies.removeReplicatorDispatchRate(String) instead.

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

Deprecated.

Use TopicPolicies.removeReplicatorDispatchRateAsync(String) instead.

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.

Use TopicPolicies.removeRetention(String) instead.

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

Deprecated.

Use TopicPolicies.removeRetentionAsync(String) instead.

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

Deprecated.

Use TopicPolicies.removeSubscribeRate(String) instead.

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

Deprecated.

Use TopicPolicies.removeSubscribeRateAsync(String) instead.

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

Deprecated.

Use TopicPolicies.removeSubscriptionDispatchRate(String) instead.

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

Deprecated.

Use TopicPolicies.removeSubscriptionDispatchRateAsync(String) instead.

removeSubscriptionDispatchRateAsync(String, String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies

Async version of TopicPolicies.removeSubscriptionDispatchRate(String, String).

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

Deprecated.

Use TopicPolicies.removeSubscriptionTypesEnabled(String) instead.

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

Deprecated.

Use TopicPolicies.removeSubscriptionTypesEnabledAsync(String) instead.

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

Deprecated.

Use TopicPolicies.setBacklogQuota(String, BacklogQuota) instead.

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

Deprecated.

Use TopicPolicies.setBacklogQuota(String, BacklogQuota, BacklogQuota.BacklogQuotaType) instead.

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

Deprecated.

Use TopicPolicies.setCompactionThreshold(String, long) instead.

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

Deprecated.

Use TopicPolicies.setCompactionThresholdAsync(String, long) instead.

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

Deprecated.

Use TopicPolicies.setDeduplicationSnapshotInterval(String, int) instead.

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

Deprecated.

Use TopicPolicies.setDeduplicationSnapshotIntervalAsync(String, int) instead.

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

Deprecated.

Use TopicPolicies.setDeduplicationStatus(String, boolean) instead.

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

Deprecated.

Use TopicPolicies.setDeduplicationStatusAsync(String, boolean) instead.

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

Deprecated.

Use TopicPolicies.setDelayedDeliveryPolicy(String, DelayedDeliveryPolicies) instead.

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

Deprecated.

Use TopicPolicies.setDelayedDeliveryPolicyAsync(String, DelayedDeliveryPolicies) instead.

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

Deprecated.

Use TopicPolicies.setDispatchRate(String, DispatchRate) instead.

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

Deprecated.

Use TopicPolicies.setDispatchRateAsync(String, DispatchRate) instead.

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

Deprecated.

Use TopicPolicies.setInactiveTopicPolicies(String, InactiveTopicPolicies) instead.

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

Deprecated.

Use TopicPolicies.setInactiveTopicPoliciesAsync(String, InactiveTopicPolicies) instead.

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

Deprecated.

Use TopicPolicies.setMaxConsumers(String, int) instead.

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

Deprecated.

Use TopicPolicies.setMaxConsumers(String, int) instead.

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

Deprecated.

Use TopicPolicies.setMaxConsumersPerSubscription(String, int) instead.

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

Deprecated.

Use TopicPolicies.setMaxConsumersPerSubscriptionAsync(String, int) instead.

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

Deprecated.

Use TopicPolicies.setMaxMessageSize(String, int) instead.

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

Deprecated.

Use TopicPolicies.setMaxMessageSizeAsync(String, int) instead.

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

Deprecated.

Use TopicPolicies.setMaxProducers(String, int) instead.

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

Deprecated.

Use TopicPolicies.setMaxProducersAsync(String, int) instead.

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

Deprecated.

Use TopicPolicies.setMaxSubscriptionsPerTopic(String, int) instead.

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

Deprecated.

Use TopicPolicies.setMaxSubscriptionsPerTopicAsync(String, int) instead.

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

Deprecated.

Use TopicPolicies.setMaxUnackedMessagesOnConsumer(String, int) instead.

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

Deprecated.

Use TopicPolicies.setMaxUnackedMessagesOnConsumerAsync(String, int) instead.

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

Deprecated.

Use TopicPolicies.setMaxUnackedMessagesOnSubscription(String, int) instead.

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

Deprecated.

Use TopicPolicies.setMaxUnackedMessagesOnSubscriptionAsync(String, int) instead.

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

Deprecated.

Use TopicPolicies.setMessageTTL(String, int) instead.

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

Deprecated.

Use TopicPolicies.setOffloadPolicies(String, OffloadPolicies) instead.

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

Deprecated.

Use TopicPolicies.setOffloadPoliciesAsync(String, OffloadPolicies) instead.

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

Deprecated.

Use TopicPolicies.setPersistence(String, PersistencePolicies) (String)} instead.

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

Deprecated.

Use TopicPolicies.setPersistenceAsync(String, PersistencePolicies) (String)} instead.

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

Deprecated.

Use TopicPolicies.setPublishRate(String, PublishRate) instead.

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

Deprecated.

Use TopicPolicies.setPublishRateAsync(String, PublishRate) instead.

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

Deprecated.

Use TopicPolicies.setReplicatorDispatchRate(String, DispatchRate) instead.

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

Deprecated.

Use TopicPolicies.setReplicatorDispatchRateAsync(String, DispatchRate) instead.

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

Deprecated.

Use TopicPolicies.setRetention(String, RetentionPolicies) instead.

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

Deprecated.

Use TopicPolicies.setRetentionAsync(String, RetentionPolicies) instead.

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

Deprecated.

Use TopicPolicies.setSubscribeRate(String, SubscribeRate) instead.

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

Deprecated.

Use TopicPolicies.setSubscribeRateAsync(String, SubscribeRate) instead.

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

Deprecated.

Use TopicPolicies.setSubscriptionDispatchRate(String, DispatchRate) instead.

setSubscriptionDispatchRateAsync(String, String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.TopicPolicies

Async version of TopicPolicies.setSubscriptionDispatchRate(String, String, DispatchRate).

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

Deprecated.

Use TopicPolicies.setSubscriptionDispatchRateAsync(String, DispatchRate) instead.

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

Deprecated.

Use TopicPolicies.setSubscriptionTypesEnabled(String, Set) instead.

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

Deprecated.

Use TopicPolicies.setSubscriptionTypesEnabledAsync(String, Set) instead.

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.

in favor of PulsarAdmin.sinks()

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.

in favor of PulsarAdmin.sources()

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