int brokerId
String reason
org.apache.kafka.clients.admin.ExclusionOp.OpType opType
kafka.common.BrokerReplicaExclusion brokerReplicaExclusion
private Object readResolve()
boolean wasSuccessful
scala.collection.immutable.Set<A> brokerReplicaExclusionResults
private Object readResolve()
int brokerId
String reason
private Object readResolve()
int brokerId
scala.Option<A> apiErrorOpt
org.apache.kafka.clients.admin.ExclusionOp.OpType opType
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
long firstOffset
long lastOffset
Duration sampleWindowSize
int numSamples
double averageServiceRequestTime
double workloadCoefficient
double MinimumHistoryPeriodInMinutes
private Object readResolve()
private Object readResolve()
private Object readResolve()
long intervalMs
int maxInprogressPartitions
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()
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()
int replicaId
long offset
long nextOffset
long checksum
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
String topic
int partitionId
int replicaId
private Object readResolve()