java.lang.String clientId
private java.lang.Object readResolve()
java.lang.String clientId
private java.lang.Object readResolve()
java.lang.String clientId
java.lang.String brokerHost
int brokerPort
private java.lang.Object readResolve()
java.lang.String clientId
java.lang.String topic
private java.lang.Object readResolve()
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 readResolve()
java.lang.String NoMetadata
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 readResolve()
java.lang.String message
long firstOffset
long lastOffset
private java.lang.Object readResolve()
private java.lang.Object readResolve()
private java.lang.Object readResolve()
private java.lang.Object readResolve()
TopicIdPartition topicIdPartition
private java.lang.Object readResolve()
TopicIdPartition topicIdPartition
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 readResolve()
int replicaId
long offset
long nextOffset
long checksum
private java.lang.Object readResolve()
private java.lang.Object readResolve()
java.lang.String topic
int partitionId
int replicaId
private java.lang.Object readResolve()