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()
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
String topic
int partitionId
int replicaId
private Object writeReplace()