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()
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
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
boolean demote
scala.Function1<T1,R> callback
private Object writeReplace()
int brokerId
long brokerEpoch
scala.collection.Map<K,V> partitionsToAlter
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
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()
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()
ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<R> callback
private Object writeReplace()
ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<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()
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()
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()
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()
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()
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()
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()