boolean wasSuccessful
scala.collection.immutable.Set<A> brokerReplicaExclusionResults
private Object readResolve()
int brokerId
String reason
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
long timestamp
TierObjectStore.ObjectMetadata metadata
int objectSize
private Object readResolve()
String message
String message
long firstOffset
long lastOffset
private Object readResolve()
int brokerId
long brokerEpoch
scala.Function1<T1,R> callback
private Object readResolve()
String reason
scala.collection.Set<A> brokerIds
org.apache.kafka.clients.admin.BrokerComponent component
org.apache.kafka.clients.admin.ComponentHealthStatus healthStatus
boolean force
short requestVersion
scala.Function1<T1,R> callback
private Object readResolve()
org.apache.kafka.common.message.AlterPartitionRequestData alterPartitionRequest
short alterPartitionRequestVersion
scala.Function1<T1,R> callback
private Object readResolve()
scala.collection.Set<A> exclusions
scala.Function1<T1,R> callback
private Object readResolve()
scala.collection.Map<K,V> reassignments
scala.Function1<T1,R> callback
private Object readResolve()
int cellId
scala.collection.Seq<A> brokers
boolean force
scala.Function1<T1,R> callback
private Object readResolve()
scala.collection.Seq<A> assignments
scala.Function1<T1,R> callback
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
kafka.controller.BrokerHealthCommand command
private Object readResolve()
private Object readResolve()
int brokerId
private Object readResolve()
kafka.controller.CellCommand command
private Object readResolve()
int cellId
org.apache.kafka.common.CellState cellState
scala.Function1<T1,R> callback
private Object readResolve()
int cellId
scala.Function1<T1,R> callback
private Object readResolve()
int cellId
org.apache.kafka.common.CellState cellState
scala.Function1<T1,R> callback
private Object readResolve()
scala.collection.Set<A> eligibleControllers
private Object readResolve()
String topic
private Object readResolve()
List<E> goalList
ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<R> callback
private Object readResolve()
private Object readResolve()
private Object readResolve()
int id
long brokerEpoch
scala.Function1<T1,R> controlledShutdownCallback
ControlledShutdownRequestReason reason
private Object readResolve()
private Object readResolve()
org.apache.kafka.clients.NetworkClient networkClient
org.apache.kafka.common.Node brokerNode
kafka.controller.ControlMetadataAccumulator messageQueue
kafka.controller.RequestSendThread requestSendThread
com.yammer.metrics.core.Gauge<T> queueSizeGauge
com.yammer.metrics.core.Timer requestRateAndTimeMetrics
scala.Option<A> reconfigurableChannelBuilder
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
scala.collection.Seq<A> responses
private Object readResolve()
kafka.controller.DataBalanceManagerCommand command
private Object readResolve()
ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<R> callback
private Object readResolve()
ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<R> callback
private Object readResolve()
short requestVersion
scala.Function1<T1,R> callback
private Object readResolve()
ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<R> callback
private Object readResolve()
List<E> cellIds
ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<R> callback
private Object readResolve()
scala.collection.Seq<A> cellIds
scala.Function1<T1,R> callback
private Object readResolve()
ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<R> callback
private Object readResolve()
scala.Function1<T1,R> callback
private Object readResolve()
scala.collection.Seq<A> tenantIds
scala.Function1<T1,R> callback
private Object readResolve()
org.apache.kafka.common.TopicPartition topicPartition
scala.Option<A> leaderAndIsr
scala.collection.Seq<A> liveReplicas
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
org.apache.kafka.clients.NetworkClient networkClient
org.apache.kafka.common.Node brokerNode
BlockingQueue<E> messageQueue
kafka.controller.KRaftRequestSendThread requestSendThread
com.yammer.metrics.core.Gauge<T> queueSizeGauge
com.yammer.metrics.core.Timer requestRateAndTimeMetrics
scala.Option<A> reconfigurableChannelBuilder
private Object readResolve()
org.apache.kafka.common.protocol.ApiKeys apiKey
org.apache.kafka.common.requests.AbstractControlRequest.Builder<T extends org.apache.kafka.common.requests.AbstractRequest> request
scala.Function1<T1,R> callback
long enqueueTimeMs
private Object readResolve()
org.apache.kafka.common.requests.LeaderAndIsrResponse leaderAndIsrResponse
int brokerId
private Object readResolve()
kafka.api.LeaderAndIsr leaderAndIsr
int controllerEpoch
private Object readResolve()
private Object readResolve()
scala.Option<A> partitionsOpt
scala.Function1<T1,R> callback
private Object readResolve()
private Object readResolve()
kafka.controller.MetadataCollectorConfig command
private Object readResolve()
boolean enable
private Object readResolve()
private Object readResolve()
byte state
scala.collection.immutable.Set<A> validPreviousStates
private Object readResolve()
byte state
scala.collection.immutable.Set<A> validPreviousStates
private Object readResolve()
byte state
scala.collection.immutable.Set<A> validPreviousStates
private Object readResolve()
byte state
scala.collection.immutable.Set<A> validPreviousStates
private Object readResolve()
byte state
scala.collection.immutable.Set<A> validPreviousStates
boolean allowUnclean
private Object readResolve()
private Object readResolve()
byte state
scala.collection.immutable.Set<A> validPreviousStates
private Object readResolve()
byte state
scala.collection.immutable.Set<A> validPreviousStates
private Object readResolve()
byte state
scala.collection.immutable.Set<A> validPreviousStates
org.apache.kafka.common.TopicPartition topicPartition
int replica
private Object readResolve()
String topic
private Object readResolve()
org.apache.kafka.common.TopicPartition partition
private Object readResolve()
private Object readResolve()
kafka.controller.ControlMetadataBatch batch
scala.Function2<T1,T2,R> callback
long enqueueTimeMs
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
List<E> brokersToRemove
boolean shouldShutdown
TopicsMetadataSnapshot topicsMetadataSnapshot
ClusterBalanceManager.BalanceManagerOperationInvocationClientCallback callback
private Object readResolve()
kafka.controller.ReplicaAssignment.Assignment originAssignment
scala.Option<A> targetAssignment
scala.collection.Seq<A> replicas
scala.collection.Seq<A> addingReplicas
scala.collection.Seq<A> removingReplicas
scala.collection.Seq<A> observers
scala.Option<A> targetObservers
byte bitmap$0
scala.collection.Seq<A> replicas
scala.collection.Seq<A> observers
private Object readResolve()
private Object readResolve()
kafka.controller.ReplicaAssignment empty
private Object readResolve()
byte state
scala.collection.immutable.Set<A> validPreviousStates
private Object readResolve()
byte state
scala.collection.immutable.Set<A> validPreviousStates
private Object readResolve()
byte state
scala.collection.immutable.Set<A> validPreviousStates
scala.Option<A> partitionsFromAdminClientOpt
org.apache.kafka.common.ElectionType electionType
kafka.controller.ElectionTrigger electionTrigger
scala.Function1<T1,R> callback
private Object readResolve()
private Object readResolve()
private Object readResolve()
kafka.controller.TenantCommand command
private Object readResolve()
scala.collection.Seq<A> tenantIds
scala.Function1<T1,R> callback
private Object readResolve()
private Object readResolve()
private Object readResolve()
int replicaId
org.apache.kafka.common.protocol.Errors requestError
scala.collection.Map<K,V> partitionErrors
private Object readResolve()
String topic
private Object readResolve()
List<E> goalList
ClusterBalanceManager.BalanceManagerOperationInvocationClientCallback callback
private Object readResolve()
scala.collection.Seq<A> brokers
scala.Function1<T1,R> callback
private Object readResolve()
private Object readResolve()
org.apache.kafka.common.requests.UpdateFeaturesRequest request
scala.Function1<T1,R> callback
private Object readResolve()
org.apache.kafka.common.protocol.Errors error
int brokerId
private Object readResolve()
private Object readResolve()
private Object readResolve()
long offset
boolean isTombstone
boolean isTransactional
private Object readResolve()
SocketChannel socket
long endThrottleTimeMs
private Object readResolve()
String ConnectionRateSensorName
String ConnectionRateMetricName
String TenantMetricTag
String IpMetricTag
long InactiveSensorExpirationTimeSeconds
String ConnectionQuotaMetricName
String entity
long startThrottleTimeMs
long throttleTimeMs
long closeTimeMs
String address
scala.Function0<R> callback
private Object readResolve()
String ip
InetAddress ip
String ConnectionRateSensorName
String ConnectionRateMetricName
String TenantMetricTag
String IpMetricTag
long InactiveSensorExpirationTimeSeconds
String ConnectionQuotaMetricName
private Object readResolve()
InetAddress ip
String listenerName
String ConnectionRateSensorName
String ConnectionRateMetricName
String TenantMetricTag
String IpMetricTag
long InactiveSensorExpirationTimeSeconds
String ConnectionQuotaMetricName
private Object readResolve()
String listenerName
String ConnectionRateSensorName
String ConnectionRateMetricName
String TenantMetricTag
String IpMetricTag
long InactiveSensorExpirationTimeSeconds
String ConnectionQuotaMetricName
private Object readResolve()
String tenantId
String listenerName
String ConnectionRateSensorName
String ConnectionRateMetricName
String TenantMetricTag
String IpMetricTag
long InactiveSensorExpirationTimeSeconds
String ConnectionQuotaMetricName
private Object readResolve()
kafka.network.RequestChannel.Response response
org.apache.kafka.common.network.Send responseSend
long connectionsMaxIdleMs
long connectionMaxAgeMs
long connectionMinExpireIntervalMs
private Object readResolve()
scala.Function1<T1,R> fun
kafka.network.RequestChannel.Request originalRequest
private Object readResolve()
org.apache.kafka.common.security.auth.KafkaPrincipal principal
InetAddress clientAddress
String sanitizedUser
private Object readResolve()
private Object readResolve()
private Object readResolve()
long lastUpdatedTime
double p99TotalTime
String tenant
String lkc
String ConnectionRateSensorName
String ConnectionRateMetricName
String TenantMetricTag
String IpMetricTag
long InactiveSensorExpirationTimeSeconds
String ConnectionQuotaMetricName
private Object readResolve()
String entity
double count
Transition<E extends Event> transition
Event event
Throwable cause
private Object readResolve()
Object result
scala.collection.Map<K,V> partitionsWithError
private Object readResolve()
org.apache.kafka.common.TopicIdPartition topicIdPartition
kafka.api.LeaderAndIsr leaderAndIsr
CompletableFuture<T> future
int controllerEpoch
private Object readResolve()
kafka.server.KafkaServer delegate
kafka.durability.ondemand.AuditJobHelper auditJobHelper
private Object readResolve()
kafka.server.BrokerServer server
kafka.durability.ondemand.AuditJobHelper auditJobHelper
private Object readResolve()
kafka.server.KafkaServer delegate
private Object readResolve()
kafka.cluster.BrokerEndPoint broker
int fetcherId
private Object readResolve()
boolean backpressureEnabledInConfig
long backpressureCheckFrequencyMs
scala.collection.Seq<A> tenantEndpointListenerNames
double maxQueueSize
double minBrokerRequestQuota
String queueSizePercentile
private Object readResolve()
long DefaultActiveWindowMs
long DefaultBackpressureCheckFrequencyMs
double DefaultMaxResourceUtilization
double DefaultMinNonExemptRequestUtilization
double MinBrokerRequestQuota
double DefaultRequestQuotaIncreasePercentFactor
double DefaultRequestQuotaDecreasePercentFactor
double RequestQuotaMinAdjustment
String clientId
org.apache.kafka.common.TopicPartition topicPartition
private Object readResolve()
String clientId
private Object readResolve()
private Object readResolve()
private Object readResolve()
scala.Option<A> userEntity
scala.Option<A> clientIdEntity
private Object readResolve()
String sanitizedUser
private Object readResolve()
int numQuotaSamples
int quotaWindowSizeSeconds
kafka.server.BrokerBackpressureConfig backpressureConfig
kafka.server.DiskUsageBasedThrottlingConfig diskThrottlingConfig
double brokerQuotaLimit
long consumptionReportingIntervalMs
int minReportedUsage
long maxThrottleTimeMs
private Object readResolve()
int InactiveSensorExpirationTimeSeconds
double NanosToPercentagePerSecond
kafka.server.SensorAccess sensorAccessor
scala.Option<A> principalOpt
scala.collection.immutable.Map<K,V> metricTags
scala.collection.immutable.Map<K,V> parentMetricTags
org.apache.kafka.common.metrics.Sensor quotaSensor
org.apache.kafka.common.metrics.Sensor throttleTimeSensor
private Object readResolve()
kafka.server.ClusterLinkReplicaQuota produce
kafka.server.ClusterLinkTenantRequestQuota request
private Object readResolve()
String ClusterLinkClientId
InetAddress ClusterLinkClientAddress
kafka.server.ReplicationQuotaManagerConfig replicationQuotaManagerConfig
scala.Function0<R> clusterLinkEnable
scala.Function0<R> clusterLinkTenantQuotasEnable
scala.Function0<R> clusterLinkQuotaMode
scala.Function0<R> clusterLinkQuotaModePerTenantOverrides
private Object readResolve()
kafka.server.ClientQuotaManagerConfig clientQuotaManagerConfig
scala.Function0<R> clusterLinkEnable
scala.Function0<R> clusterLinkTenantQuotasEnable
scala.Function0<R> clusterLinkRequestQuotaCapacity
private Object readResolve()
scala.Option<A> tenant
String linkName
private Object readResolve()
private Object readResolve()
private Object readResolve()
scala.Option<A> node
org.apache.kafka.common.network.ListenerName listenerName
org.apache.kafka.common.security.auth.SecurityProtocol securityProtocol
String saslMechanism
boolean isZkController
private Object readResolve()
kafka.zk.KafkaZkClient zkClient
org.apache.kafka.metadata.migration.KRaftMigrationDriver migrationDriver
org.apache.kafka.metadata.migration.LegacyPropagator brokersRpcClient
private Object readResolve()
String topic
scala.collection.Set<A> partitions
org.apache.kafka.common.requests.ApiError error
private Object readResolve()
org.apache.kafka.common.security.auth.KafkaPrincipal owner
org.apache.kafka.common.security.auth.KafkaPrincipal tokenRequester
long issueTimestamp
long expiryTimestamp
long maxTimestamp
String tokenId
byte[] hmac
org.apache.kafka.common.protocol.Errors error
private Object readResolve()
long requiredOffset
org.apache.kafka.common.message.DeleteRecordsResponseData.DeleteRecordsPartitionResult responseStatus
boolean acksPending
private Object readResolve()
String topic
org.apache.kafka.common.protocol.Errors error
private Object readResolve()
long freeDiskThresholdBytes
long throttledProduceThroughput
scala.collection.Seq<A> logDirs
boolean enableDiskBasedThrottling
long diskCheckFrequencyMs
double freeDiskThresholdBytesRecoveryFactor
boolean clusterLinkEnabled
private Object readResolve()
long MinDiskThresholdBytes
long MinThroughputBytesPerSec
long DefaultDiskCheckFrequencyMs
double MinFreeDiskRecoveryFactor
com.typesafe.scalalogging.Logger logger
String logIdent
boolean bitmap$0
String saslJaasConfigName
org.apache.kafka.common.security.JaasContext jaasContext
String saslMechanism
scala.collection.Set<A> dynamicConfigs
String prefix
org.apache.kafka.common.security.authenticator.LoginManager loginManager
com.typesafe.scalalogging.Logger logger
String logIdent
boolean bitmap$0
private Object readResolve()
boolean privileged
int size
int id
private Object readResolve()
private Object readResolve()
private Object readResolve()
int brokerId
int fetcherId
kafka.server.FetcherPool fetcherPool
private Object readResolve()
private Object readResolve()
org.apache.kafka.storage.internals.log.LogOffsetMetadata startOffsetMetadata
org.apache.kafka.common.requests.FetchRequest.PartitionData fetchInfo
private Object readResolve()
org.apache.kafka.common.Uuid topicId
long fetchOffset
long startOffset
int maxBytes
Optional<T> currentLeaderEpoch
Optional<T> lastFetchedEpoch
long replicationSessionId
org.apache.kafka.storage.internals.log.LogOffsetMetadata fetchOffsetMetadata
private Object readResolve()
String groupId
private Object readResolve()
String groupId
private Object readResolve()
kafka.cluster.Partition partition
private Object readResolve()
scala.Option<A> topicId
kafka.cluster.BrokerEndPoint leader
int currentLeaderEpoch
long initOffset
scala.Option<A> replicationSessionId
private Object readResolve()
long checkIntervalMs
long maxDelayMs
long lingerMs
private Object readResolve()
scala.collection.Set<A> authorizedTopics
scala.collection.Set<A> unauthorizedForCreateTopics
scala.collection.Set<A> unauthorizedForDescribeTopics
scala.collection.Seq<A> unknownTopicIdsTopicMetadata
scala.collection.Set<A> validTopicIds
private Object readResolve()
private Object readResolve()
kafka.server.KafkaServer delegate
kafka.server.KafkaTopicPartitionRestoreManager helper
private Object readResolve()
kafka.server.BrokerServer server
kafka.server.KafkaTopicPartitionRestoreManager restoreHelper
private Object readResolve()
kafka.server.BrokerServer delegate
private Object readResolve()
int id
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
org.apache.kafka.common.Uuid topicId
org.apache.kafka.metadata.PartitionRegistration partition
private Object readResolve()
org.apache.kafka.storage.internals.log.LogAppendInfo info
scala.Option<A> exception
private Object readResolve()
long requestedOffset
long lowWatermark
scala.Option<A> exception
private Object readResolve()
org.apache.kafka.storage.internals.log.FetchDataInfo info
scala.Option<A> divergingEpoch
long highWatermark
long leaderLogStartOffset
long leaderLogEndOffset
long followerLogStartOffset
long fetchTimeMs
scala.Option<A> lastStableOffset
boolean isReadAllowed
boolean highOrLowWatermarkUpdated
scala.Option<A> preferredReadReplica
scala.Option<A> exception
long readLatencyNanos
private Object readResolve()
private Object readResolve()
String clusterId
int nodeId
private Object readResolve()
long createdTimeMs
org.apache.kafka.common.requests.AbstractRequest.Builder<T extends org.apache.kafka.common.requests.AbstractRequest> request
kafka.server.ControllerRequestCompletionHandler callback
private Object readResolve()
long offset
boolean truncationCompleted
scala.Option<A> currentLeaderEpoch
private Object readResolve()
scala.Option<A> topicId
long fetchOffset
scala.Option<A> lag
int currentLeaderEpoch
scala.Option<A> delay
kafka.server.ReplicaState state
scala.Option<A> lastFetchedEpoch
scala.Option<A> replicationSessionId
int failedAttempts
private Object readResolve()
short produceRequiredAcks
scala.collection.Map<K,V> produceStatus
private Object readResolve()
long requiredOffset
org.apache.kafka.common.requests.ProduceResponse.PartitionResponse responseStatus
boolean acksPending
private Object readResolve()
int cacheLimit
int cachePerTenantPercent
private Object readResolve()
int currentLeaderEpoch
scala.Option<A> replicationSessionId
private Object readResolve()
kafka.server.ClientQuotaManager fetch
kafka.server.ClientQuotaManager produce
kafka.server.ClientRequestQuotaManager request
kafka.server.ControllerMutationQuotaManager controllerMutation
scala.Option<A> producerId
kafka.server.ReplicationQuotaManager leader
kafka.server.ReplicationQuotaManager follower
kafka.server.ReplicationQuotaManager alterLogDirs
kafka.server.ClusterLinkReplicationQuotaManager clusterLinkProduce
kafka.server.ClusterLinkRequestQuotaManager clusterLinkRequest
scala.Option<A> clientQuotaCallback
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
kafka.server.ForwardingManager fwdMgr
kafka.server.metadata.KRaftMetadataCache metadataCache
scala.Option<A> forwardingManager
private Object readResolve()
scala.collection.Seq<A> deletedPartitions
kafka.server.ReplicaManager.MirrorTopicChanges mirrorTopicChanges
private Object readResolve()
scala.collection.Set<A> pendingStoppedMirrorTopics
scala.collection.Set<A> pendingMirrorTopics
scala.collection.Set<A> pendingSynchronizeMirrorTopics
private Object readResolve()
long quotaBytesPerSecond
int numQuotaSamples
int quotaWindowSizeSeconds
boolean allReplicasThrottled
private Object readResolve()
int InactiveSensorExpirationTimeSeconds
String LeaderReplicationThrottledRateProp
String FollowerReplicationThrottledRateProp
String LeaderReplicationThrottledReplicasProp
String FollowerReplicationThrottledReplicasProp
scala.collection.Set<A> ReconfigurableConfigs
org.apache.kafka.common.utils.BufferSupplier bufferSupplier
private Object readResolve()
kafka.server.RequestLocal NoCaching
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
org.apache.kafka.common.TopicPartition topicPartition
boolean deleteLocalLog
private Object readResolve()
String name
AtomicLong currentWriteStartedMs
com.yammer.metrics.core.Histogram histogram
com.yammer.metrics.core.Gauge<T> heartbeat
com.yammer.metrics.core.Gauge<T> latencyWindowedAvg
com.yammer.metrics.core.Gauge<T> latencyWindowedMax
com.yammer.metrics.core.Gauge<T> slowWriteCount
String topic
int partition
org.apache.kafka.common.Uuid id
private Object readResolve()
kafka.tier.fetcher.TierFetchDataInfo info
scala.Option<A> divergingEpoch
long highWatermark
long leaderLogStartOffset
long leaderLogEndOffset
long followerLogStartOffset
long fetchTimeMs
int readSize
scala.Option<A> lastStableOffset
scala.Option<A> preferredReadReplica
scala.Option<A> exception
long readLatencyNanos
org.apache.kafka.common.record.Records records
private Object readResolve()
UUID objectId
int restoreEpoch
private Object readResolve()
org.apache.kafka.common.Uuid id
private Object readResolve()
long localLogStartOffset
scala.Option<A> tierRestorePoint
private Object readResolve()
scala.Option<A> replicaManagerOpt
scala.Option<A> fetcherOpt
scala.Option<A> stateFetcherOpt
kafka.log.TierLogComponents logComponents
private Object readResolve()
kafka.server.TierReplicaComponents EMPTY
scala.collection.Seq<A> leaderEpochState
scala.Option<A> producerState
private Object readResolve()
String topic
private Object readResolve()
String topic
int partition
private Object readResolve()
private Object readResolve()
String user
scala.Option<A> mechanism
boolean legalRequest
int iterations
int id
private Object readResolve()
String clusterId
int brokerId
private Object readResolve()
kafka.server.ZkAdminManager adminManager
kafka.controller.KafkaController controller
kafka.zk.KafkaZkClient zkClient
scala.Option<A> forwardingManager
kafka.server.metadata.ZkMetadataCache metadataCache
kafka.server.BrokerEpochManager brokerEpochManager
private Object readResolve()
org.apache.kafka.common.metrics.Metrics metrics
org.apache.kafka.common.metrics.Sensor almostOOMSensor
MemoryPoolMXBean memoryPoolMxBean
org.apache.kafka.common.MetricName almostOOMMetricName
long usageThresholdBytes
boolean wasShutdown
private Object readResolve()
private Object readResolve()
long intervalMs
int maxInprogressPartitions
long deleteBackoffMs
private Object readResolve()
long deletePreInitiateRecordTime
boolean isDeleteInitiated
private Object readResolve()
boolean isDeletePreInitiated
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()
private Object readResolve()
TopicIdPartition topicIdPartition
private Object readResolve()
private Object readResolve()
long delayTimeMs
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
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()
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