boolean wasSuccessful
scala.collection.immutable.Set<A> brokerReplicaExclusionResults
private Object writeReplace()
int brokerId
String reason
private Object writeReplace()
String clientId
private Object writeReplace()
private Object writeReplace()
long timestamp
long offset
scala.Option<A> leaderEpoch
scala.Option<A> followerRestorePoint
scala.Option<A> responseException
private Object writeReplace()
private Object writeReplace()
kafka.log.LogSegment segment
long offset
private Object writeReplace()
long creationTimeMs
org.apache.kafka.common.Node destination
org.apache.kafka.common.requests.AbstractRequest.Builder<T extends org.apache.kafka.common.requests.AbstractRequest> request
org.apache.kafka.clients.RequestCompletionHandler handler
private Object writeReplace()
long timestamp
TierObjectStore.ObjectMetadata metadata
int objectSize
private Object writeReplace()
String message
String message
long firstOffset
long lastOffset
private Object writeReplace()
int brokerId
long brokerEpoch
scala.Function1<T1,R> callback
private Object writeReplace()
String reason
scala.collection.Set<A> brokerIds
org.apache.kafka.clients.admin.BrokerComponent component
org.apache.kafka.clients.admin.ComponentHealthStatus healthStatus
boolean force
short requestVersion
scala.Function1<T1,R> callback
private Object writeReplace()
org.apache.kafka.common.message.AlterPartitionRequestData alterPartitionRequest
short alterPartitionRequestVersion
scala.Function1<T1,R> callback
private Object writeReplace()
scala.collection.Set<A> exclusions
scala.Function1<T1,R> callback
private Object writeReplace()
scala.collection.Map<K,V> reassignments
scala.Function1<T1,R> callback
private Object writeReplace()
int cellId
scala.collection.Seq<A> brokers
boolean force
scala.Function1<T1,R> callback
private Object writeReplace()
scala.collection.Seq<A> assignments
scala.Function1<T1,R> callback
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
kafka.controller.BrokerHealthCommand command
private Object writeReplace()
private Object writeReplace()
int brokerId
private Object writeReplace()
kafka.controller.CellCommand command
private Object writeReplace()
int cellId
org.apache.kafka.common.CellState cellState
scala.Function1<T1,R> callback
private Object writeReplace()
int cellId
scala.Function1<T1,R> callback
private Object writeReplace()
int cellId
org.apache.kafka.common.CellState cellState
scala.Function1<T1,R> callback
private Object writeReplace()
scala.collection.Set<A> eligibleControllers
private Object writeReplace()
String topic
private Object writeReplace()
ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<R> callback
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
int id
long brokerEpoch
scala.Function1<T1,R> controlledShutdownCallback
ControlledShutdownRequestReason reason
private Object writeReplace()
private Object writeReplace()
org.apache.kafka.clients.NetworkClient networkClient
org.apache.kafka.common.Node brokerNode
kafka.controller.ControlMetadataAccumulator messageQueue
kafka.controller.RequestSendThread requestSendThread
com.yammer.metrics.core.Gauge<T> queueSizeGauge
com.yammer.metrics.core.Timer requestRateAndTimeMetrics
scala.Option<A> reconfigurableChannelBuilder
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
scala.collection.Seq<A> responses
private Object writeReplace()
kafka.controller.DataBalanceManagerCommand command
private Object writeReplace()
ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<R> callback
private Object writeReplace()
ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<R> callback
private Object writeReplace()
short requestVersion
scala.Function1<T1,R> callback
private Object writeReplace()
ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<R> callback
private Object writeReplace()
List<E> cellIds
ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<R> callback
private Object writeReplace()
scala.collection.Seq<A> cellIds
scala.Function1<T1,R> callback
private Object writeReplace()
ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<R> callback
private Object writeReplace()
scala.Function1<T1,R> callback
private Object writeReplace()
scala.collection.Seq<A> tenantIds
scala.Function1<T1,R> callback
private Object writeReplace()
org.apache.kafka.common.TopicPartition topicPartition
scala.Option<A> leaderAndIsr
scala.collection.Seq<A> liveReplicas
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
org.apache.kafka.clients.NetworkClient networkClient
org.apache.kafka.common.Node brokerNode
BlockingQueue<E> messageQueue
kafka.controller.KRaftRequestSendThread requestSendThread
com.yammer.metrics.core.Gauge<T> queueSizeGauge
com.yammer.metrics.core.Timer requestRateAndTimeMetrics
scala.Option<A> reconfigurableChannelBuilder
private Object writeReplace()
org.apache.kafka.common.protocol.ApiKeys apiKey
org.apache.kafka.common.requests.AbstractControlRequest.Builder<T extends org.apache.kafka.common.requests.AbstractRequest> request
scala.Function1<T1,R> callback
long enqueueTimeMs
private Object writeReplace()
org.apache.kafka.common.requests.LeaderAndIsrResponse leaderAndIsrResponse
int brokerId
private Object writeReplace()
kafka.api.LeaderAndIsr leaderAndIsr
int controllerEpoch
private Object writeReplace()
private Object writeReplace()
scala.Option<A> partitionsOpt
scala.Function1<T1,R> callback
private Object writeReplace()
private Object writeReplace()
kafka.controller.MetadataCollectorConfig command
private Object writeReplace()
boolean enable
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
boolean allowUnclean
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
org.apache.kafka.common.TopicPartition topicPartition
int replica
private Object writeReplace()
String topic
private Object writeReplace()
org.apache.kafka.common.TopicPartition partition
private Object writeReplace()
private Object writeReplace()
kafka.controller.ControlMetadataBatch batch
scala.Function2<T1,T2,R> callback
long enqueueTimeMs
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
List<E> brokersToRemove
boolean shouldShutdown
TopicsMetadataSnapshot topicsMetadataSnapshot
ClusterBalanceManager.BalanceManagerOperationInvocationClientCallback callback
private Object writeReplace()
kafka.controller.ReplicaAssignment.Assignment originAssignment
scala.Option<A> targetAssignment
scala.collection.Seq<A> replicas
scala.collection.Seq<A> addingReplicas
scala.collection.Seq<A> removingReplicas
scala.collection.Seq<A> observers
scala.Option<A> targetObservers
byte bitmap$0
scala.collection.Seq<A> replicas
scala.collection.Seq<A> observers
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
scala.Option<A> partitionsFromAdminClientOpt
org.apache.kafka.common.ElectionType electionType
kafka.controller.ElectionTrigger electionTrigger
scala.Function1<T1,R> callback
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
kafka.controller.TenantCommand command
private Object writeReplace()
scala.collection.Seq<A> tenantIds
scala.Function1<T1,R> callback
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
int replicaId
org.apache.kafka.common.protocol.Errors requestError
scala.collection.Map<K,V> partitionErrors
private Object writeReplace()
String topic
private Object writeReplace()
ClusterBalanceManager.BalanceManagerOperationInvocationClientCallback callback
private Object writeReplace()
scala.collection.Seq<A> brokers
scala.Function1<T1,R> callback
private Object writeReplace()
private Object writeReplace()
org.apache.kafka.common.requests.UpdateFeaturesRequest request
scala.Function1<T1,R> callback
private Object writeReplace()
org.apache.kafka.common.protocol.Errors error
int brokerId
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
long offset
boolean isTombstone
boolean isTransactional
private Object writeReplace()
Transition<E extends Event> transition
Event event
Throwable cause
private Object writeReplace()
Object result
scala.collection.Map<K,V> partitionsWithError
private Object writeReplace()
private Object writeReplace()
org.apache.kafka.common.TopicIdPartition topicIdPartition
kafka.api.LeaderAndIsr leaderAndIsr
CompletableFuture<T> future
int controllerEpoch
private Object writeReplace()
kafka.server.KafkaServer delegate
kafka.durability.ondemand.AuditJobHelper auditJobHelper
private Object writeReplace()
kafka.server.BrokerServer server
kafka.durability.ondemand.AuditJobHelper auditJobHelper
private Object writeReplace()
kafka.server.KafkaServer delegate
private Object writeReplace()
kafka.cluster.BrokerEndPoint broker
int fetcherId
private Object writeReplace()
boolean backpressureEnabledInConfig
long backpressureCheckFrequencyMs
scala.collection.Seq<A> tenantEndpointListenerNames
double maxQueueSize
double minBrokerRequestQuota
String queueSizePercentile
private Object writeReplace()
long createdTimeMs
org.apache.kafka.common.requests.AbstractRequest.Builder<T extends org.apache.kafka.common.requests.AbstractRequest> request
kafka.server.ControllerRequestCompletionHandler callback
private Object writeReplace()
String clientId
org.apache.kafka.common.TopicPartition topicPartition
private Object writeReplace()
String clientId
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
scala.Option<A> userEntity
scala.Option<A> clientIdEntity
private Object writeReplace()
String sanitizedUser
private Object writeReplace()
int numQuotaSamples
int quotaWindowSizeSeconds
kafka.server.BrokerBackpressureConfig backpressureConfig
kafka.server.DiskUsageBasedThrottlingConfig diskThrottlingConfig
double brokerQuotaLimit
long consumptionReportingIntervalMs
int minReportedUsage
private Object writeReplace()
scala.collection.immutable.Map<K,V> metricTags
scala.collection.immutable.Map<K,V> parentMetricTags
org.apache.kafka.common.metrics.Sensor quotaSensor
org.apache.kafka.common.metrics.Sensor throttleTimeSensor
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
scala.Option<A> node
org.apache.kafka.common.network.ListenerName listenerName
org.apache.kafka.common.security.auth.SecurityProtocol securityProtocol
String saslMechanism
boolean isZkController
private Object writeReplace()
kafka.zk.KafkaZkClient zkClient
org.apache.kafka.metadata.migration.KRaftMigrationDriver migrationDriver
org.apache.kafka.metadata.migration.LegacyPropagator brokersRpcClient
private Object writeReplace()
String topic
scala.collection.Set<A> partitions
org.apache.kafka.common.requests.ApiError error
private Object writeReplace()
org.apache.kafka.common.security.auth.KafkaPrincipal owner
org.apache.kafka.common.security.auth.KafkaPrincipal tokenRequester
long issueTimestamp
long expiryTimestamp
long maxTimestamp
String tokenId
byte[] hmac
org.apache.kafka.common.protocol.Errors error
private Object writeReplace()
long requiredOffset
org.apache.kafka.common.message.DeleteRecordsResponseData.DeleteRecordsPartitionResult responseStatus
boolean acksPending
private Object writeReplace()
String topic
org.apache.kafka.common.protocol.Errors error
private Object writeReplace()
long freeDiskThresholdBytes
long throttledProduceThroughput
scala.collection.Seq<A> logDirs
boolean enableDiskBasedThrottling
long diskCheckFrequencyMs
double freeDiskThresholdBytesRecoveryFactor
boolean clusterLinkEnabled
private Object writeReplace()
String saslJaasConfigName
org.apache.kafka.common.security.JaasContext jaasContext
String saslMechanism
scala.collection.Set<A> dynamicConfigs
String prefix
org.apache.kafka.common.security.authenticator.LoginManager loginManager
com.typesafe.scalalogging.Logger logger
String logIdent
boolean bitmap$0
private Object writeReplace()
boolean privileged
int size
int id
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
int brokerId
int fetcherId
kafka.server.FetcherPool fetcherPool
private Object writeReplace()
private Object writeReplace()
org.apache.kafka.common.Uuid topicId
long fetchOffset
long startOffset
int maxBytes
Optional<T> currentLeaderEpoch
Optional<T> lastFetchedEpoch
org.apache.kafka.storage.internals.log.LogOffsetMetadata fetchOffsetMetadata
private Object writeReplace()
String groupId
private Object writeReplace()
String groupId
private Object writeReplace()
kafka.cluster.Partition partition
private Object writeReplace()
scala.Option<A> topicId
kafka.cluster.BrokerEndPoint leader
int currentLeaderEpoch
long initOffset
private Object writeReplace()
private Object writeReplace()
long checkIntervalMs
long maxDelayMs
long lingerMs
private Object writeReplace()
scala.collection.Set<A> authorizedTopics
scala.collection.Set<A> unauthorizedForCreateTopics
scala.collection.Set<A> unauthorizedForDescribeTopics
scala.collection.Seq<A> unknownTopicIdsTopicMetadata
scala.collection.Set<A> validTopicIds
private Object writeReplace()
private Object writeReplace()
kafka.server.KafkaServer delegate
kafka.server.KafkaTopicPartitionRestoreManager helper
private Object writeReplace()
kafka.server.BrokerServer server
kafka.server.KafkaTopicPartitionRestoreManager restoreHelper
private Object writeReplace()
kafka.server.BrokerServer delegate
private Object writeReplace()
int id
private Object writeReplace()
private Object writeReplace()
org.apache.kafka.common.Uuid topicId
org.apache.kafka.metadata.PartitionRegistration partition
private Object writeReplace()
org.apache.kafka.storage.internals.log.LogAppendInfo info
scala.Option<A> exception
private Object writeReplace()
long requestedOffset
long lowWatermark
scala.Option<A> exception
private Object writeReplace()
org.apache.kafka.storage.internals.log.FetchDataInfo info
scala.Option<A> divergingEpoch
long highWatermark
long leaderLogStartOffset
long leaderLogEndOffset
long followerLogStartOffset
long fetchTimeMs
scala.Option<A> lastStableOffset
boolean isReadAllowed
boolean highOrLowWatermarkUpdated
scala.Option<A> preferredReadReplica
scala.Option<A> exception
long readLatencyNanos
private Object writeReplace()
private Object writeReplace()
String clusterId
int nodeId
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
long offset
boolean truncationCompleted
scala.Option<A> currentLeaderEpoch
private Object writeReplace()
scala.Option<A> topicId
long fetchOffset
scala.Option<A> lag
int currentLeaderEpoch
scala.Option<A> delay
kafka.server.ReplicaState state
scala.Option<A> lastFetchedEpoch
int failedAttempts
private Object writeReplace()
short produceRequiredAcks
scala.collection.Map<K,V> produceStatus
private Object writeReplace()
long requiredOffset
org.apache.kafka.common.requests.ProduceResponse.PartitionResponse responseStatus
boolean acksPending
private Object writeReplace()
int cacheLimit
int cachePerTenantPercent
private Object writeReplace()
kafka.server.ClientQuotaManager fetch
kafka.server.ClientQuotaManager produce
kafka.server.ClientRequestQuotaManager request
kafka.server.ControllerMutationQuotaManager controllerMutation
scala.Option<A> producerId
kafka.server.ReplicationQuotaManager leader
kafka.server.ReplicationQuotaManager follower
kafka.server.ReplicationQuotaManager alterLogDirs
kafka.server.ReplicationQuotaManager clusterLink
scala.Option<A> clientQuotaCallback
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
kafka.server.ForwardingManager fwdMgr
kafka.server.metadata.KRaftMetadataCache metadataCache
scala.Option<A> forwardingManager
private Object writeReplace()
scala.collection.Seq<A> deletedPartitions
scala.collection.Set<A> pendingStoppedMirrorTopics
private Object writeReplace()
long quotaBytesPerSecond
int numQuotaSamples
int quotaWindowSizeSeconds
boolean allReplicasThrottled
private Object writeReplace()
org.apache.kafka.common.utils.BufferSupplier bufferSupplier
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
String name
AtomicLong currentWriteStartedMs
com.yammer.metrics.core.Histogram histogram
com.yammer.metrics.core.Gauge<T> heartbeat
com.yammer.metrics.core.Gauge<T> latencyWindowedAvg
com.yammer.metrics.core.Gauge<T> latencyWindowedMax
com.yammer.metrics.core.Gauge<T> slowWriteCount
String topic
int partition
org.apache.kafka.common.Uuid id
private Object writeReplace()
kafka.tier.fetcher.TierFetchDataInfo info
scala.Option<A> divergingEpoch
long highWatermark
long leaderLogStartOffset
long leaderLogEndOffset
long followerLogStartOffset
long fetchTimeMs
int readSize
scala.Option<A> lastStableOffset
scala.Option<A> preferredReadReplica
scala.Option<A> exception
long readLatencyNanos
org.apache.kafka.common.record.Records records
private Object writeReplace()
UUID objectId
int restoreEpoch
private Object writeReplace()
org.apache.kafka.common.Uuid id
private Object writeReplace()
long localLogStartOffset
scala.Option<A> tierRestorePoint
private Object writeReplace()
scala.Option<A> replicaManagerOpt
scala.Option<A> fetcherOpt
scala.Option<A> stateFetcherOpt
kafka.log.TierLogComponents logComponents
private Object writeReplace()
scala.collection.Seq<A> leaderEpochState
scala.Option<A> producerState
private Object writeReplace()
String topic
private Object writeReplace()
String topic
int partition
private Object writeReplace()
private Object writeReplace()
String user
scala.Option<A> mechanism
boolean legalRequest
int iterations
int id
private Object writeReplace()
String clusterId
int brokerId
private Object writeReplace()
kafka.server.ZkAdminManager adminManager
kafka.controller.KafkaController controller
kafka.zk.KafkaZkClient zkClient
scala.Option<A> forwardingManager
kafka.server.metadata.ZkMetadataCache metadataCache
kafka.server.BrokerEpochManager brokerEpochManager
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
long intervalMs
int maxInprogressPartitions
long deleteBackoffMs
private Object writeReplace()
long deletePreInitiateRecordTime
boolean isDeleteInitiated
private Object writeReplace()
boolean isDeletePreInitiated
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
TopicIdPartition topicIdPartition
TopicIdPartition topicIdPartition
private Object writeReplace()
TopicIdPartition topicIdPartition
private Object writeReplace()
TopicIdPartition topicIdPartition
private Object writeReplace()
TopicIdPartition topicIdPartition
TopicIdPartition topicIdPartition
private Object writeReplace()
TopicIdPartition topicIdPartition
private Object writeReplace()
TopicIdPartition topicIdPartition
TopicIdPartition topicIdPartition
private Object writeReplace()
private Object writeReplace()
TopicIdPartition topicIdPartition
private Object writeReplace()
private Object writeReplace()
long delayTimeMs
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
org.apache.kafka.common.TopicPartition topicPartition
long fetchStartOffset
Integer maxBytes
long maxPosition
boolean minOneMessage
TierObjectStore.ObjectMetadata segmentMetadata
scala.Option<A> transactionMetadata
long segmentBaseOffset
int segmentSize
private Object writeReplace()
kafka.tools.TopicPartitionFilter[] filters
private Object writeReplace()
int replicaId
long offset
long nextOffset
long checksum
private Object writeReplace()
int lowerRange
int upperRange
private Object writeReplace()
scala.collection.immutable.Set<A> partitionIds
private Object writeReplace()
private Object writeReplace()
long offset
long appendTimeMs
private Object writeReplace()
int epoch
org.apache.kafka.raft.BatchReader<T> reader
org.apache.kafka.snapshot.SnapshotReader<T> reader
kafka.utils.IncludeList topicFilter
kafka.tools.PartitionFilter partitionFilter
private Object writeReplace()
String topic
int partitionId
int replicaId
private Object writeReplace()
int partition
private Object writeReplace()
String rawRegex
private Object writeReplace()