Index
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(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 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.
- 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
- 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
- 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
- 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.
- 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).
- 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.
- 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.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.
- 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.
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.
- enableDeduplicationAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
-
Deprecated.
- 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.
- 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.
- 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.
- getAutoSubscriptionCreationAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
-
Get the autoSubscriptionCreation info within a namespace 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
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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
- 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
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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).
- 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.
- 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
- 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.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.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
- 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
- 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
- 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
-
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
- 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
-
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
- 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.
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
- 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
fromPulsarAdmin.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
- 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.
- removeAutoSubscriptionCreationAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
-
Removes the autoSubscriptionCreation policy for a given namespace 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.
- 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.
- 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.
- 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.
- 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. - 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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. - 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. - 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.
- 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.
- 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.
- 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.
- 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, int) - 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
- 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.
- setAutoSubscriptionCreationAsync(String, AutoSubscriptionCreationOverride) - Method in interface org.apache.pulsar.client.admin.Namespaces
-
Sets the autoSubscriptionCreation policy for a given namespace, overriding broker 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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
-
<<<<<<< HEAD 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
- 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
-
Shutdown current broker gracefully.
- 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
- 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
- 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).
- TransactionBufferStats - Class in org.apache.pulsar.common.policies.data
- TransactionBufferStats() - Constructor for class org.apache.pulsar.common.policies.data.TransactionBufferStats
- 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.
- 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.delete(String, boolean)
instead because parameter `deleteSchema` is always true