- id - Variable in class org.apache.kafka.admin.BrokerMetadata
-
- id() - Method in class org.apache.kafka.metadata.TopicPlacement.Replica
-
- ImmutableMap<K,V> - Interface in org.apache.kafka.server.immutable
-
A persistent Hash-based Map wrapper.
- ImmutableNavigableMap<K,V> - Interface in org.apache.kafka.server.immutable
-
A persistent Tree-based Navigable Map wrapper.
- ImmutableNavigableSet<E> - Interface in org.apache.kafka.server.immutable
-
A persistent Tree-based NavigableSet wrapper
java.util.Set methods that mutate in-place will throw UnsupportedOperationException
- ImmutableSet<E> - Interface in org.apache.kafka.server.immutable
-
A persistent Hash-based Set wrapper
java.util.Set methods that mutate in-place will throw UnsupportedOperationException
- IncludeList(String) - Constructor for class org.apache.kafka.server.util.TopicFilter.IncludeList
-
- increment() - Method in class org.apache.kafka.timeline.TimelineInteger
-
- increment() - Method in class org.apache.kafka.timeline.TimelineLong
-
- indexOf(Object) - Method in class org.apache.kafka.server.mutable.BoundedList
-
- INIT - Static variable in class org.apache.kafka.timeline.TimelineInteger
-
- INIT - Static variable in class org.apache.kafka.timeline.TimelineLong
-
- initializeBootstrapProperties(Properties, Optional<String>) - Static method in class org.apache.kafka.server.util.CommandLineUtils
-
- initializeBootstrapProperties(OptionParser, OptionSet, Properties, OptionSpec<String>) - Static method in class org.apache.kafka.server.util.CommandLineUtils
-
- initiateShutdown() - Method in class org.apache.kafka.server.util.ShutdownableThread
-
- INSTANCE - Static variable in class org.apache.kafka.queue.EventQueue.NoDeadlineFunction
-
- INSTANCE - Static variable in class org.apache.kafka.queue.EventQueue.VoidEvent
-
- INSTANCE - Static variable in class org.apache.kafka.server.metrics.KafkaYammerMetrics
-
- interBrokerEndpoint() - Method in class org.apache.kafka.server.network.KafkaAuthorizerServerInfo
-
- InterBrokerSendThread - Class in org.apache.kafka.server.util
-
An inter-broker send thread that utilizes a non-blocking network client.
- InterBrokerSendThread(String, KafkaClient, int, Time) - Constructor for class org.apache.kafka.server.util.InterBrokerSendThread
-
- InterBrokerSendThread(String, KafkaClient, int, Time, boolean) - Constructor for class org.apache.kafka.server.util.InterBrokerSendThread
-
- io.confluent.kafka.concurrent - package io.confluent.kafka.concurrent
-
- io.confluent.kafka.link - package io.confluent.kafka.link
-
- io.confluent.kafka.multitenant - package io.confluent.kafka.multitenant
-
- IP_TAG - Static variable in class io.confluent.kafka.multitenant.TenantUtils
-
- IS_SUPPORTED_FFF_CLIENT_TAG - Static variable in class io.confluent.kafka.multitenant.TenantUtils
-
- isAllocateProducerIdsSupported() - Method in enum org.apache.kafka.server.common.MetadataVersion
-
- isAlterMirrorsRequestSupported() - Method in enum org.apache.kafka.server.common.MetadataVersion
-
- isAlterPartitionSupported() - Method in enum org.apache.kafka.server.common.MetadataVersion
-
- isApiForwardingEnabled() - Method in enum org.apache.kafka.server.common.MetadataVersion
-
- isAtLeast(MetadataVersion) - Method in enum org.apache.kafka.server.common.MetadataVersion
-
- isBrokerRegistrationChangeRecordSupported() - Method in enum org.apache.kafka.server.common.MetadataVersion
-
- isCellsSupported() - Method in enum org.apache.kafka.server.common.MetadataVersion
-
- isClusterLinkModeSupported() - Method in enum org.apache.kafka.server.common.MetadataVersion
-
- isDelegationTokenSupported() - Method in enum org.apache.kafka.server.common.MetadataVersion
-
- isEmpty() - Method in interface org.apache.kafka.queue.EventQueue
-
- isEmpty() - Method in class org.apache.kafka.server.immutable.pcollections.PCollectionsImmutableMap
-
- isEmpty() - Method in class org.apache.kafka.server.immutable.pcollections.PCollectionsImmutableNavigableMap
-
- isEmpty() - Method in class org.apache.kafka.server.immutable.pcollections.PCollectionsImmutableNavigableSet
-
- isEmpty() - Method in class org.apache.kafka.server.immutable.pcollections.PCollectionsImmutableSet
-
- isEmpty() - Method in class org.apache.kafka.server.mutable.BoundedList
-
- isEmpty() - Method in class org.apache.kafka.server.util.TranslatedValueMapView
-
- isEmpty() - Method in class org.apache.kafka.timeline.TimelineHashMap
-
- isEmpty(long) - Method in class org.apache.kafka.timeline.TimelineHashMap
-
- isEmpty() - Method in class org.apache.kafka.timeline.TimelineHashSet
-
- isEmpty(long) - Method in class org.apache.kafka.timeline.TimelineHashSet
-
- isFeatureVersioningSupported() - Method in enum org.apache.kafka.server.common.MetadataVersion
-
- isFetchFromFollowerEnabled(String, String, Set<String>) - Static method in class io.confluent.kafka.multitenant.ZoneUtils
-
- isInControlledShutdownStateSupported() - Method in enum org.apache.kafka.server.common.MetadataVersion
-
- isKRaftSupported() - Method in enum org.apache.kafka.server.common.MetadataVersion
-
- isLeaderEpochBumpRequiredOnIsrShrink() - Method in enum org.apache.kafka.server.common.MetadataVersion
-
- isLeaderRecoverySupported() - Method in enum org.apache.kafka.server.common.MetadataVersion
-
- isLessThan(MetadataVersion) - Method in enum org.apache.kafka.server.common.MetadataVersion
-
- isLinkCoordinatorSupported() - Method in enum org.apache.kafka.server.common.MetadataVersion
-
- isMetadataTransactionSupported() - Method in enum org.apache.kafka.server.common.MetadataVersion
-
- isMigrationSupported() - Method in enum org.apache.kafka.server.common.MetadataVersion
-
- isMinTierFeatureSupported() - Method in enum org.apache.kafka.server.common.MetadataVersion
-
- isNoOpRecordSupported() - Method in enum org.apache.kafka.server.common.MetadataVersion
-
- isOffsetForLeaderEpochSupported() - Method in enum org.apache.kafka.server.common.MetadataVersion
-
- isPartitionAllowed(int) - Method in interface org.apache.kafka.server.util.PartitionFilter
-
Used to filter partitions based on a certain criteria, for example, a set of partition ids.
- isPartitionAllowed(int) - Method in class org.apache.kafka.server.util.PartitionFilter.PartitionRangeFilter
-
- isPartitionAllowed(int) - Method in class org.apache.kafka.server.util.PartitionFilter.PartitionsSetFilter
-
- isPartitionAllowed(int) - Method in class org.apache.kafka.server.util.PartitionFilter.UniquePartitionFilter
-
- isPrintHelpNeeded(CommandDefaultOptions) - Static method in class org.apache.kafka.server.util.CommandLineUtils
-
Check if there are no options or `--help` option from command line.
- isPrintVersionNeeded(CommandDefaultOptions) - Static method in class org.apache.kafka.server.util.CommandLineUtils
-
Check if there is `--version` option from command line.
- isRunning() - Method in class org.apache.kafka.server.util.ShutdownableThread
-
- isSaslInterBrokerHandshakeRequestEnabled() - Method in enum org.apache.kafka.server.common.MetadataVersion
-
- isScramSupported() - Method in enum org.apache.kafka.server.common.MetadataVersion
-
- isSettingBrokerHealthSupported() - Method in enum org.apache.kafka.server.common.MetadataVersion
-
- isShutdownComplete() - Method in class org.apache.kafka.server.util.ShutdownableThread
-
- isShutdownInitiated() - Method in class org.apache.kafka.server.util.ShutdownableThread
-
- isStarted() - Method in class org.apache.kafka.server.util.KafkaScheduler
-
- isSubset(Map<String, String>, Map<String, String>) - Static method in class org.apache.kafka.metadata.TopicPlacement.ConstraintCount
-
- isThreadFailed() - Method in class org.apache.kafka.server.util.ShutdownableThread
-
- isTopicAllowed(String, boolean) - Method in class org.apache.kafka.server.util.TopicFilter.IncludeList
-
- isTopicAllowed(String, boolean) - Method in class org.apache.kafka.server.util.TopicFilter
-
- isTopicAllowed(String) - Method in class org.apache.kafka.server.util.TopicPartitionFilter.CompositeTopicPartitionFilter
-
- isTopicAllowed(String) - Method in interface org.apache.kafka.server.util.TopicPartitionFilter
-
Used to filter topics based on a certain criteria, for example, a set of topic names or a regular expression.
- isTopicAllowed(String) - Method in class org.apache.kafka.server.util.TopicPartitionFilter.TopicFilterAndPartitionFilter
-
- isTopicIdsSupported() - Method in enum org.apache.kafka.server.common.MetadataVersion
-
- isTopicPartitionAllowed(TopicPartition) - Method in class org.apache.kafka.server.util.TopicPartitionFilter.CompositeTopicPartitionFilter
-
- isTopicPartitionAllowed(TopicPartition) - Method in interface org.apache.kafka.server.util.TopicPartitionFilter
-
Used to filter topic-partitions based on a certain criteria, for example, a topic pattern and a set of partition ids.
- isTopicPartitionAllowed(TopicPartition) - Method in class org.apache.kafka.server.util.TopicPartitionFilter.TopicFilterAndPartitionFilter
-
- isTopicPlacementSupported() - Method in enum org.apache.kafka.server.common.MetadataVersion
-
- isTruncationOnFetchSupported() - Method in enum org.apache.kafka.server.common.MetadataVersion
-
- iterator() - Method in class org.apache.kafka.server.immutable.pcollections.PCollectionsImmutableNavigableSet
-
- iterator() - Method in class org.apache.kafka.server.immutable.pcollections.PCollectionsImmutableSet
-
- iterator() - Method in class org.apache.kafka.server.mutable.BoundedList
-
- iterator() - Method in class org.apache.kafka.server.util.json.JsonArray
-
- iterator() - Method in class org.apache.kafka.server.util.json.JsonObject
-
- iterator() - Method in class org.apache.kafka.timeline.SnapshotRegistry
-
Returns a snapshot iterator that iterates from the snapshots with the
lowest epoch to those with the highest.
- iterator(long) - Method in class org.apache.kafka.timeline.SnapshotRegistry
-
Returns a snapshot iterator that iterates from the snapshots with the
lowest epoch to those with the highest, starting at the snapshot with the
given epoch.
- iterator(Snapshot) - Method in class org.apache.kafka.timeline.SnapshotRegistry
-
Returns a snapshot iterator that iterates from the snapshots with the
lowest epoch to those with the highest, starting at the given snapshot.
- iterator() - Method in class org.apache.kafka.timeline.TimelineHashSet
-
- iterator(long) - Method in class org.apache.kafka.timeline.TimelineHashSet
-
- schedule(Runnable, long, TimeUnit) - Method in class io.confluent.kafka.concurrent.DefaultEventExecutor
-
- schedule(Callable<T>, long, TimeUnit) - Method in class io.confluent.kafka.concurrent.DefaultEventExecutor
-
- schedule(Runnable, long, TimeUnit) - Method in interface io.confluent.kafka.concurrent.EventExecutor
-
Submits a task for delayed execution.
- schedule(Callable<T>, long, TimeUnit) - Method in interface io.confluent.kafka.concurrent.EventExecutor
-
Submits a task for delayed execution.
- schedule(String, Runnable, long, long) - Method in class org.apache.kafka.server.util.KafkaScheduler
-
- schedule(String, Runnable, long, long) - Method in interface org.apache.kafka.server.util.Scheduler
-
Schedule a task.
- scheduleDeferred(String, Function<OptionalLong, OptionalLong>, EventQueue.Event) - Method in interface org.apache.kafka.queue.EventQueue
-
Schedule an event to be run at a specific time.
- scheduleOnce(String, Runnable) - Method in interface org.apache.kafka.server.util.Scheduler
-
- scheduleOnce(String, Runnable, long) - Method in interface org.apache.kafka.server.util.Scheduler
-
- Scheduler - Interface in org.apache.kafka.server.util
-
A scheduler for running jobs
This interface controls a job scheduler that allows scheduling either repeating background jobs
that execute periodically or delayed one-time actions that are scheduled in the future.
- serialize(ApiMessageAndVersion) - Method in class org.apache.kafka.server.common.serialization.BytesApiMessageSerde
-
- serverSynonym(String) - Static method in class org.apache.kafka.server.config.ServerTopicConfigSynonyms
-
Return the server config with the highest priority for `topicConfigName` if it exists.
- ServerTopicConfigSynonyms - Class in org.apache.kafka.server.config
-
- ServerTopicConfigSynonyms() - Constructor for class org.apache.kafka.server.config.ServerTopicConfigSynonyms
-
- set(int, E) - Method in class org.apache.kafka.server.mutable.BoundedList
-
- set(int) - Method in class org.apache.kafka.timeline.TimelineInteger
-
- set(long) - Method in class org.apache.kafka.timeline.TimelineLong
-
- set(T) - Method in class org.apache.kafka.timeline.TimelineObject
-
- setAction(Runnable) - Method in class org.apache.kafka.server.fault.ProcessTerminatingFaultHandler.Builder
-
Set the Runnable
to run when handling a fault.
- setMaxActionsPerWindow(int) - Method in class org.apache.kafka.server.util.RateLimiter.Builder
-
- setShouldHalt(boolean) - Method in class org.apache.kafka.server.fault.ProcessTerminatingFaultHandler.Builder
-
Set if halt or exit should be used.
- setTime(Time) - Method in class org.apache.kafka.server.util.RateLimiter.Builder
-
- setWindowLength(int) - Method in class org.apache.kafka.server.util.RateLimiter.Builder
-
- shortConfluentRelease() - Method in enum org.apache.kafka.server.common.MetadataVersion
-
- shortVersion() - Method in enum org.apache.kafka.server.common.MetadataVersion
-
- shouldApply() - Method in class org.apache.kafka.server.common.BrokerReplicaExclusionModificationResult
-
- shouldThrottle(long, long) - Method in class org.apache.kafka.server.util.ThroughputThrottler
-
- shutdown() - Method in class io.confluent.kafka.concurrent.DefaultEventExecutor
-
- shutdown() - Method in interface io.confluent.kafka.concurrent.EventExecutor
-
Shuts down the event executor.
- shutdown() - Method in class org.apache.kafka.server.util.InterBrokerSendThread
-
- shutdown() - Method in class org.apache.kafka.server.util.KafkaScheduler
-
- shutdown() - Method in interface org.apache.kafka.server.util.Scheduler
-
Shutdown this scheduler.
- shutdown() - Method in class org.apache.kafka.server.util.ShutdownableThread
-
- ShutdownableThread - Class in org.apache.kafka.server.util
-
- ShutdownableThread(String) - Constructor for class org.apache.kafka.server.util.ShutdownableThread
-
- ShutdownableThread(String, boolean) - Constructor for class org.apache.kafka.server.util.ShutdownableThread
-
- ShutdownableThread(String, boolean, String) - Constructor for class org.apache.kafka.server.util.ShutdownableThread
-
- singleton(K, V) - Static method in interface org.apache.kafka.server.immutable.ImmutableMap
-
- singleton(K, V) - Static method in interface org.apache.kafka.server.immutable.ImmutableNavigableMap
-
- singleton(E) - Static method in interface org.apache.kafka.server.immutable.ImmutableNavigableSet
-
- singleton(E) - Static method in interface org.apache.kafka.server.immutable.ImmutableSet
-
- singleton(K, V) - Static method in class org.apache.kafka.server.immutable.pcollections.PCollectionsImmutableMap
-
- singleton(K, V) - Static method in class org.apache.kafka.server.immutable.pcollections.PCollectionsImmutableNavigableMap
-
- singleton(E) - Static method in class org.apache.kafka.server.immutable.pcollections.PCollectionsImmutableNavigableSet
-
- singleton(E) - Static method in class org.apache.kafka.server.immutable.pcollections.PCollectionsImmutableSet
-
- size() - Method in interface org.apache.kafka.queue.EventQueue
-
- size() - Method in class org.apache.kafka.queue.KafkaEventQueue
-
- size() - Method in class org.apache.kafka.server.common.ProducerIdsBlock
-
Get the number of IDs contained in this block.
- size() - Method in class org.apache.kafka.server.immutable.pcollections.PCollectionsImmutableMap
-
- size() - Method in class org.apache.kafka.server.immutable.pcollections.PCollectionsImmutableNavigableMap
-
- size() - Method in class org.apache.kafka.server.immutable.pcollections.PCollectionsImmutableNavigableSet
-
- size() - Method in class org.apache.kafka.server.immutable.pcollections.PCollectionsImmutableSet
-
- size() - Method in class org.apache.kafka.server.mutable.BoundedList
-
- size() - Method in class org.apache.kafka.server.util.KafkaScheduler
-
- size() - Method in interface org.apache.kafka.server.util.Scheduler
-
Returns the number of pending tasks.
- size() - Method in class org.apache.kafka.server.util.timer.SystemTimer
-
- size() - Method in interface org.apache.kafka.server.util.timer.Timer
-
Get the number of tasks pending execution
- size() - Method in class org.apache.kafka.timeline.TimelineHashMap
-
- size(long) - Method in class org.apache.kafka.timeline.TimelineHashMap
-
- size() - Method in class org.apache.kafka.timeline.TimelineHashSet
-
- size(long) - Method in class org.apache.kafka.timeline.TimelineHashSet
-
- SnapshotRegistry - Class in org.apache.kafka.timeline
-
A registry containing snapshots of timeline data structures.
- SnapshotRegistry(LogContext) - Constructor for class org.apache.kafka.timeline.SnapshotRegistry
-
- spliterator() - Method in class org.apache.kafka.server.immutable.pcollections.PCollectionsImmutableNavigableSet
-
- spliterator() - Method in class org.apache.kafka.server.immutable.pcollections.PCollectionsImmutableSet
-
- startup() - Method in class org.apache.kafka.server.util.KafkaScheduler
-
- startup() - Method in interface org.apache.kafka.server.util.Scheduler
-
Initialize this scheduler so it is ready to accept scheduling of tasks
- stream() - Method in class org.apache.kafka.server.immutable.pcollections.PCollectionsImmutableNavigableSet
-
- stream() - Method in class org.apache.kafka.server.immutable.pcollections.PCollectionsImmutableSet
-
- subList(int, int) - Method in class org.apache.kafka.server.mutable.BoundedList
-
- subMap(K, boolean, K, boolean) - Method in class org.apache.kafka.server.immutable.pcollections.PCollectionsImmutableNavigableMap
-
- subMap(K, K) - Method in class org.apache.kafka.server.immutable.pcollections.PCollectionsImmutableNavigableMap
-
- submit(Runnable) - Method in class io.confluent.kafka.concurrent.DefaultEventExecutor
-
- submit(Callable<T>) - Method in class io.confluent.kafka.concurrent.DefaultEventExecutor
-
- submit(Runnable) - Method in interface io.confluent.kafka.concurrent.EventExecutor
-
Submits a task for immediate execution.
- submit(Callable<T>) - Method in interface io.confluent.kafka.concurrent.EventExecutor
-
Submits a task for immediate execution.
- subSet(E, boolean, E, boolean) - Method in class org.apache.kafka.server.immutable.pcollections.PCollectionsImmutableNavigableSet
-
- subSet(E, E) - Method in class org.apache.kafka.server.immutable.pcollections.PCollectionsImmutableNavigableSet
-
- SystemTimer - Class in org.apache.kafka.server.util.timer
-
- SystemTimer(String) - Constructor for class org.apache.kafka.server.util.timer.SystemTimer
-
- SystemTimer(String, long, int, long) - Constructor for class org.apache.kafka.server.util.timer.SystemTimer
-
- validateAssignment(TopicPlacement, List<TopicPlacement.Replica>, List<TopicPlacement.Replica>) - Static method in class org.apache.kafka.metadata.TopicPlacement
-
Returns an error string if the sync and observer replica assignment doesn't match the constraints.
- validateLinkNameOrThrow(String) - Static method in class io.confluent.kafka.link.ClusterLinkUtils
-
Validates the provided cluster link name, ensuring it's non-empty and contains only legal characters.
- validateReconfiguration(Map<String, ?>) - Method in class org.apache.kafka.server.metrics.KafkaYammerMetrics
-
- validateZoneAlignment(Set<String>, String, String) - Static method in class io.confluent.kafka.multitenant.ZoneUtils
-
- VALIDATOR - Static variable in class org.apache.kafka.metadata.TopicPlacement
-
- valueOf(String) - Static method in enum io.confluent.kafka.link.ClusterLinkConfig.LinkMode
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum io.confluent.kafka.multitenant.ZoneAlignment
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.apache.kafka.metadata.TopicPlacement.ObserverPromotionPolicy
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.apache.kafka.queue.EventQueue.EventInsertionType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.apache.kafka.server.common.MetadataVersion
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.apache.kafka.server.record.BrokerCompressionType
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum io.confluent.kafka.link.ClusterLinkConfig.LinkMode
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum io.confluent.kafka.multitenant.ZoneAlignment
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum org.apache.kafka.metadata.TopicPlacement.ObserverPromotionPolicy
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum org.apache.kafka.queue.EventQueue.EventInsertionType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum org.apache.kafka.server.common.MetadataVersion
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Method in class org.apache.kafka.server.immutable.pcollections.PCollectionsImmutableMap
-
- values() - Method in class org.apache.kafka.server.immutable.pcollections.PCollectionsImmutableNavigableMap
-
- values() - Static method in enum org.apache.kafka.server.record.BrokerCompressionType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Method in class org.apache.kafka.timeline.TimelineHashMap
-
- values(long) - Method in class org.apache.kafka.timeline.TimelineHashMap
-
- version() - Method in class org.apache.kafka.metadata.TopicPlacement
-
- version() - Method in class org.apache.kafka.server.common.ApiMessageAndVersion
-
- version() - Method in enum org.apache.kafka.server.common.MetadataVersion
-
- versionOpt - Variable in class org.apache.kafka.server.util.CommandDefaultOptions
-
- VERSIONS - Static variable in enum org.apache.kafka.server.common.MetadataVersion
-
- VoidCallable - Class in io.confluent.kafka.concurrent
-
- VoidCallable(Runnable) - Constructor for class io.confluent.kafka.concurrent.VoidCallable
-
- VoidEvent() - Constructor for class org.apache.kafka.queue.EventQueue.VoidEvent
-