java.lang.String clientId
private java.lang.Object writeReplace()
java.lang.String clientId
private java.lang.Object writeReplace()
java.lang.String clientId
java.lang.String brokerHost
int brokerPort
private java.lang.Object writeReplace()
java.lang.String clientId
java.lang.String topic
private java.lang.Object writeReplace()
kafka.log.LogSegment segment
long offset
long offset
java.util.Optional<T> leaderEpoch
java.lang.String metadata
long commitTimestamp
scala.Option<A> expireTimestamp
private java.lang.Object writeReplace()
org.apache.kafka.common.errors.ApiException invalidException
scala.collection.Seq<A> recordErrors
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 java.lang.Object writeReplace()
java.lang.String message
long firstOffset
long lastOffset
private java.lang.Object writeReplace()
private java.lang.Object writeReplace()
private java.lang.Object writeReplace()
private java.lang.Object writeReplace()
TopicIdPartition topicIdPartition
TopicIdPartition topicIdPartition
private java.lang.Object writeReplace()
TopicIdPartition topicIdPartition
private java.lang.Object writeReplace()
TopicIdPartition topicIdPartition
private java.lang.Object writeReplace()
TopicIdPartition topicIdPartition
TopicIdPartition topicIdPartition
private java.lang.Object writeReplace()
TopicIdPartition topicIdPartition
private java.lang.Object writeReplace()
TopicIdPartition topicIdPartition
TopicIdPartition topicIdPartition
private java.lang.Object writeReplace()
org.apache.kafka.common.TopicPartition topicPartition
long fetchStartOffset
java.lang.Integer maxBytes
long maxPosition
boolean minOneMessage
TierObjectStore.ObjectMetadata segmentMetadata
scala.Option<A> transactionMetadata
long segmentBaseOffset
int segmentSize
private java.lang.Object writeReplace()
int replicaId
long offset
long nextOffset
long checksum
private java.lang.Object writeReplace()
private java.lang.Object writeReplace()
java.lang.String topic
int partitionId
int replicaId
private java.lang.Object writeReplace()