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
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()
Duration sampleWindowSize
int numSamples
double averageServiceRequestTime
double workloadCoefficient
double MinimumHistoryPeriodInMinutes
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
private Object writeReplace()
long intervalMs
int maxInprogressPartitions
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()
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()