int brokerId
String reason
org.apache.kafka.clients.admin.ExclusionOp.OpType opType
kafka.common.BrokerReplicaExclusion brokerReplicaExclusion
private Object writeReplace()
boolean wasSuccessful
scala.collection.immutable.Set<A> brokerReplicaExclusionResults
private Object writeReplace()
int brokerId
String reason
private Object writeReplace()
int brokerId
scala.Option<A> apiErrorOpt
org.apache.kafka.clients.admin.ExclusionOp.OpType opType
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()
org.apache.kafka.common.errors.ApiException invalidException
scala.collection.Seq<A> recordErrors
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
long firstOffset
long lastOffset
private Object writeReplace()
int brokerId
long brokerEpoch
scala.Function1<T1,R> callback
private Object writeReplace()
int brokerId
long brokerEpoch
scala.collection.Map<K,V> isrsToAlter
scala.Function1<T1,R> callback
private Object writeReplace()
String reason
scala.collection.Set<A> brokerIds
boolean demote
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()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
int brokerId
private Object writeReplace()
scala.collection.Set<A> eligibleControllers
private Object writeReplace()
String topic
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
int id
long brokerEpoch
scala.Function1<T1,R> controlledShutdownCallback
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()
scala.collection.Seq<A> responses
private Object writeReplace()
kafka.controller.DataBalanceManagerCommand command
private Object writeReplace()
scala.Function1<T1,R> callback
private Object writeReplace()
scala.Function1<T1,R> callback
private Object writeReplace()
scala.Function1<T1,R> callback
private Object writeReplace()
scala.Function1<T1,R> callback
private Object writeReplace()
scala.Function1<T1,R> callback
private Object writeReplace()
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()
boolean shouldApply
scala.collection.Map<K,V> modifiedExclusions
scala.collection.Set<A> responseResults
org.apache.kafka.common.requests.LeaderAndIsrResponse leaderAndIsrResponse
int brokerId
private Object writeReplace()
kafka.api.LeaderAndIsr leaderAndIsr
int controllerEpoch
private Object writeReplace()
private Object writeReplace()
kafka.controller.LeadershipPriorityCommand command
private Object writeReplace()
private Object writeReplace()
scala.Option<A> partitionsOpt
scala.Function1<T1,R> callback
private Object writeReplace()
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()
BrokerRemovalRequest removalRequest
scala.Function1<T1,R> 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()
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()
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()
private Object writeReplace()
Duration sampleWindowSize
int numSamples
double averageServiceRequestTime
double workloadCoefficient
Duration delayMetricStartMs
boolean tenantTaggedMetricEnabled
Duration updateMetricTagIntervalMs
double weightsLowerBound
double weightsUpperBound
double MinimumHistoryPeriodInMinutes
private Object writeReplace()
int updatedGroupSize
int rebalancingGroupSize
int failedGroupSize
int expiredGroupSize
long metricsSize
long executionTime
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
Transition<E extends Event> transition
Event event
Throwable cause
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()
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()
int replicaId
long offset
long nextOffset
long checksum
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
String topic
int partitionId
int replicaId
private Object writeReplace()
String rawRegex
private Object writeReplace()