boolean wasSuccessful
scala.collection.immutable.Set<A> brokerReplicaExclusionResults
private Object readResolve()
int brokerId
String reason
private Object readResolve()
String clientId
private Object readResolve()
private Object readResolve()
long timestamp
long offset
scala.Option<A> leaderEpoch
scala.Option<A> followerRestorePoint
scala.Option<A> responseException
private Object readResolve()
private Object readResolve()
kafka.log.LogSegment segment
long offset
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 readResolve()
long timestamp
TierObjectStore.ObjectMetadata metadata
int objectSize
private Object readResolve()
String message
String message
long firstOffset
long lastOffset
private Object readResolve()
int brokerId
long brokerEpoch
scala.Function1<T1,R> callback
private Object readResolve()
String reason
scala.collection.Set<A> brokerIds
boolean demote
boolean force
scala.Function1<T1,R> callback
private Object readResolve()
org.apache.kafka.common.message.AlterPartitionRequestData alterPartitionRequest
short alterPartitionRequestVersion
scala.Function1<T1,R> callback
private Object readResolve()
scala.collection.Set<A> exclusions
scala.Function1<T1,R> callback
private Object readResolve()
scala.collection.Map<K,V> reassignments
scala.Function1<T1,R> callback
private Object readResolve()
int cellId
scala.collection.Seq<A> brokers
scala.Function1<T1,R> callback
private Object readResolve()
scala.collection.Seq<A> assignments
scala.Function1<T1,R> callback
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
kafka.controller.BrokerHealthCommand command
private Object readResolve()
private Object readResolve()
int brokerId
private Object readResolve()
kafka.controller.CellCommand command
private Object readResolve()
int cellId
org.apache.kafka.common.CellState cellState
scala.Function1<T1,R> callback
private Object readResolve()
int cellId
scala.Function1<T1,R> callback
private Object readResolve()
int cellId
org.apache.kafka.common.CellState cellState
scala.Function1<T1,R> callback
private Object readResolve()
scala.collection.Set<A> eligibleControllers
private Object readResolve()
String topic
private Object readResolve()
ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<R> callback
private Object readResolve()
private Object readResolve()
private Object readResolve()
int id
long brokerEpoch
scala.Function1<T1,R> controlledShutdownCallback
ControlledShutdownRequestReason reason
private Object readResolve()
private Object readResolve()
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 readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
scala.collection.Seq<A> responses
private Object readResolve()
kafka.controller.DataBalanceManagerCommand command
private Object readResolve()
ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<R> callback
private Object readResolve()
ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<R> callback
private Object readResolve()
scala.Function1<T1,R> callback
private Object readResolve()
ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<R> callback
private Object readResolve()
List<E> cellIds
ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<R> callback
private Object readResolve()
scala.collection.Seq<A> cellIds
scala.Function1<T1,R> callback
private Object readResolve()
ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<R> callback
private Object readResolve()
scala.Function1<T1,R> callback
private Object readResolve()
scala.collection.Seq<A> tenantIds
scala.Function1<T1,R> callback
private Object readResolve()
org.apache.kafka.common.TopicPartition topicPartition
scala.Option<A> leaderAndIsr
scala.collection.Seq<A> liveReplicas
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
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 readResolve()
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 readResolve()
org.apache.kafka.common.requests.LeaderAndIsrResponse leaderAndIsrResponse
int brokerId
private Object readResolve()
kafka.api.LeaderAndIsr leaderAndIsr
int controllerEpoch
private Object readResolve()
private Object readResolve()
scala.Option<A> partitionsOpt
scala.Function1<T1,R> callback
private Object readResolve()
private Object readResolve()
kafka.controller.MetadataCollectorConfig command
private Object readResolve()
boolean enable
private Object readResolve()
private Object readResolve()
byte state
scala.collection.immutable.Set<A> validPreviousStates
private Object readResolve()
byte state
scala.collection.immutable.Set<A> validPreviousStates
private Object readResolve()
byte state
scala.collection.immutable.Set<A> validPreviousStates
private Object readResolve()
byte state
scala.collection.immutable.Set<A> validPreviousStates
private Object readResolve()
byte state
scala.collection.immutable.Set<A> validPreviousStates
boolean allowUnclean
private Object readResolve()
private Object readResolve()
byte state
scala.collection.immutable.Set<A> validPreviousStates
private Object readResolve()
byte state
scala.collection.immutable.Set<A> validPreviousStates
private Object readResolve()
byte state
scala.collection.immutable.Set<A> validPreviousStates
org.apache.kafka.common.TopicPartition topicPartition
int replica
private Object readResolve()
String topic
private Object readResolve()
org.apache.kafka.common.TopicPartition partition
private Object readResolve()
private Object readResolve()
kafka.controller.ControlMetadataBatch batch
scala.Function2<T1,T2,R> callback
long enqueueTimeMs
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
List<E> brokersToRemove
boolean shouldShutdown
TopicsMetadataSnapshot topicsMetadataSnapshot
ClusterBalanceManager.BalanceManagerOperationInvocationClientCallback callback
private Object readResolve()
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 readResolve()
private Object readResolve()
kafka.controller.ReplicaAssignment empty
private Object readResolve()
byte state
scala.collection.immutable.Set<A> validPreviousStates
private Object readResolve()
byte state
scala.collection.immutable.Set<A> validPreviousStates
private Object readResolve()
byte state
scala.collection.immutable.Set<A> validPreviousStates
scala.Option<A> partitionsFromAdminClientOpt
org.apache.kafka.common.ElectionType electionType
kafka.controller.ElectionTrigger electionTrigger
scala.Function1<T1,R> callback
private Object readResolve()
private Object readResolve()
private Object readResolve()
kafka.controller.TenantCommand command
private Object readResolve()
scala.collection.Seq<A> tenantIds
scala.Function1<T1,R> callback
private Object readResolve()
private Object readResolve()
private Object readResolve()
int replicaId
org.apache.kafka.common.protocol.Errors requestError
scala.collection.Map<K,V> partitionErrors
private Object readResolve()
String topic
private Object readResolve()
ClusterBalanceManager.BalanceManagerOperationInvocationClientCallback callback
private Object readResolve()
scala.collection.Seq<A> brokers
scala.Function1<T1,R> callback
private Object readResolve()
private Object readResolve()
org.apache.kafka.common.requests.UpdateFeaturesRequest request
scala.Function1<T1,R> callback
private Object readResolve()
org.apache.kafka.common.protocol.Errors error
int brokerId
private Object readResolve()
private Object readResolve()
private Object readResolve()
long offset
boolean isTombstone
boolean isTransactional
private Object readResolve()
Transition<E extends Event> transition
Event event
Throwable cause
private Object readResolve()
private Object readResolve()
long intervalMs
int maxInprogressPartitions
long deleteBackoffMs
private Object readResolve()
long deletePreInitiateRecordTime
boolean isDeleteInitiated
private Object readResolve()
boolean isDeletePreInitiated
private Object readResolve()
private Object readResolve()
private Object readResolve()
TopicIdPartition topicIdPartition
TopicIdPartition topicIdPartition
private Object readResolve()
TopicIdPartition topicIdPartition
private Object readResolve()
TopicIdPartition topicIdPartition
private Object readResolve()
TopicIdPartition topicIdPartition
TopicIdPartition topicIdPartition
private Object readResolve()
TopicIdPartition topicIdPartition
private Object readResolve()
TopicIdPartition topicIdPartition
TopicIdPartition topicIdPartition
private Object readResolve()
private Object readResolve()
TopicIdPartition topicIdPartition
private Object readResolve()
long delayTimeMs
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
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 readResolve()
kafka.tools.TopicPartitionFilter[] filters
private Object readResolve()
int replicaId
long offset
long nextOffset
long checksum
private Object readResolve()
int lowerRange
int upperRange
private Object readResolve()
scala.collection.immutable.Set<A> partitionIds
private Object readResolve()
private Object readResolve()
long offset
long appendTimeMs
private Object readResolve()
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 readResolve()
String topic
int partitionId
int replicaId
private Object readResolve()
int partition
private Object readResolve()
String rawRegex
private Object readResolve()