Overview
Package
Class
Tree
Deprecated
Index
Help
PREV NEXT
FRAMES
NO FRAMES
All Classes
Hierarchy For All Packages
Package Hierarchies:
org.apache.kafka.clients
,
org.apache.kafka.clients.consumer
,
org.apache.kafka.clients.producer
,
org.apache.kafka.clients.producer.internals
,
org.apache.kafka.clients.tools
,
org.apache.kafka.common
,
org.apache.kafka.common.config
,
org.apache.kafka.common.errors
,
org.apache.kafka.common.message
,
org.apache.kafka.common.metrics
,
org.apache.kafka.common.metrics.stats
,
org.apache.kafka.common.network
,
org.apache.kafka.common.protocol
,
org.apache.kafka.common.protocol.types
,
org.apache.kafka.common.record
,
org.apache.kafka.common.requests
,
org.apache.kafka.common.utils
Class Hierarchy
java.lang.Object
org.apache.kafka.common.config.
AbstractConfig
org.apache.kafka.clients.consumer.
ConsumerConfig
org.apache.kafka.clients.producer.
ProducerConfig
org.apache.kafka.common.utils.
AbstractIterator
<T> (implements java.util.Iterator<E>)
org.apache.kafka.common.record.
MemoryRecords.RecordsIterator
org.apache.kafka.common.requests.
AbstractRequestResponse
org.apache.kafka.common.requests.
ConsumerMetadataRequest
org.apache.kafka.common.requests.
ConsumerMetadataResponse
org.apache.kafka.common.requests.
FetchRequest
org.apache.kafka.common.requests.
FetchResponse
org.apache.kafka.common.requests.
HeartbeatRequest
org.apache.kafka.common.requests.
HeartbeatResponse
org.apache.kafka.common.requests.
JoinGroupRequest
org.apache.kafka.common.requests.
JoinGroupResponse
org.apache.kafka.common.requests.
ListOffsetRequest
org.apache.kafka.common.requests.
ListOffsetResponse
org.apache.kafka.common.requests.
MetadataRequest
org.apache.kafka.common.requests.
MetadataResponse
org.apache.kafka.common.requests.
OffsetCommitRequest
org.apache.kafka.common.requests.
OffsetCommitResponse
org.apache.kafka.common.requests.
OffsetFetchRequest
org.apache.kafka.common.requests.
OffsetFetchResponse
org.apache.kafka.common.requests.
ProduceRequest
org.apache.kafka.common.requests.
ProduceResponse
org.apache.kafka.common.requests.
RequestHeader
org.apache.kafka.common.requests.
ResponseHeader
org.apache.kafka.clients.producer.internals.
BufferPool
org.apache.kafka.common.network.
ByteBufferReceive
(implements org.apache.kafka.common.network.
Receive
)
org.apache.kafka.common.network.
ByteBufferSend
(implements org.apache.kafka.common.network.
Send
)
org.apache.kafka.common.network.
NetworkSend
org.apache.kafka.common.requests.
RequestSend
org.apache.kafka.clients.
ClientRequest
org.apache.kafka.clients.
ClientResponse
org.apache.kafka.common.utils.
ClientUtils
org.apache.kafka.common.
Cluster
org.apache.kafka.common.utils.
CollectionUtils
org.apache.kafka.common.metrics.
CompoundStat.NamedMeasurable
org.apache.kafka.common.record.
Compressor
org.apache.kafka.common.config.
ConfigDef
org.apache.kafka.common.config.
ConfigDef.Range
(implements org.apache.kafka.common.config.
ConfigDef.Validator
)
org.apache.kafka.common.config.
ConfigDef.ValidString
(implements org.apache.kafka.common.config.
ConfigDef.Validator
)
org.apache.kafka.clients.consumer.
ConsumerRecord
org.apache.kafka.clients.consumer.
ConsumerRecords
org.apache.kafka.common.utils.
CopyOnWriteMap
<K,V> (implements java.util.concurrent.ConcurrentMap<K,V>)
org.apache.kafka.common.utils.
Crc32
(implements java.util.zip.Checksum)
org.apache.kafka.clients.producer.internals.
ErrorLoggingCallback
(implements org.apache.kafka.clients.producer.
Callback
)
org.apache.kafka.common.requests.
FetchRequest.PartitionData
org.apache.kafka.common.requests.
FetchResponse.PartitionData
org.apache.kafka.common.protocol.types.
Field
org.apache.kafka.clients.producer.internals.
FutureRecordMetadata
(implements java.util.concurrent.Future<V>)
org.apache.kafka.common.metrics.stats.
Histogram
org.apache.kafka.common.metrics.stats.
Histogram.ConstantBinScheme
(implements org.apache.kafka.common.metrics.stats.
Histogram.BinScheme
)
org.apache.kafka.common.metrics.stats.
Histogram.LinearBinScheme
(implements org.apache.kafka.common.metrics.stats.
Histogram.BinScheme
)
java.io.InputStream (implements java.io.Closeable)
org.apache.kafka.common.record.
ByteBufferInputStream
java.io.FilterInputStream
org.apache.kafka.common.message.
KafkaLZ4BlockInputStream
org.apache.kafka.common.metrics.
JmxReporter
(implements org.apache.kafka.common.metrics.
MetricsReporter
)
org.apache.kafka.clients.consumer.
KafkaConsumer
(implements org.apache.kafka.clients.consumer.
Consumer
)
org.apache.kafka.common.message.
KafkaLZ4BlockOutputStream.BD
org.apache.kafka.common.message.
KafkaLZ4BlockOutputStream.FLG
org.apache.kafka.common.metrics.
KafkaMetric
(implements org.apache.kafka.common.
Metric
)
org.apache.kafka.clients.producer.
KafkaProducer
(implements org.apache.kafka.clients.producer.
Producer
)
org.apache.kafka.common.requests.
ListOffsetRequest.PartitionData
org.apache.kafka.common.requests.
ListOffsetResponse.PartitionData
org.apache.kafka.common.record.
LogEntry
org.apache.kafka.common.record.
MemoryRecords
(implements org.apache.kafka.common.record.
Records
)
org.apache.kafka.clients.producer.internals.
Metadata
org.apache.kafka.common.metrics.
MetricConfig
org.apache.kafka.common.metrics.
Metrics
org.apache.kafka.clients.consumer.
MockConsumer
(implements org.apache.kafka.clients.consumer.
Consumer
)
org.apache.kafka.clients.producer.
MockProducer
(implements org.apache.kafka.clients.producer.
Producer
)
org.apache.kafka.clients.
NetworkClient
(implements org.apache.kafka.clients.
KafkaClient
)
org.apache.kafka.common.network.
NetworkReceive
(implements org.apache.kafka.common.network.
Receive
)
org.apache.kafka.common.
Node
org.apache.kafka.common.requests.
OffsetCommitRequest.PartitionData
org.apache.kafka.common.requests.
OffsetFetchResponse.PartitionData
org.apache.kafka.clients.consumer.
OffsetMetadata
java.io.OutputStream (implements java.io.Closeable, java.io.Flushable)
org.apache.kafka.common.record.
ByteBufferOutputStream
java.io.FilterOutputStream
org.apache.kafka.common.message.
KafkaLZ4BlockOutputStream
org.apache.kafka.clients.producer.internals.
Partitioner
org.apache.kafka.common.
PartitionInfo
org.apache.kafka.common.metrics.stats.
Percentile
org.apache.kafka.clients.producer.internals.
ProduceRequestResult
org.apache.kafka.common.requests.
ProduceResponse.PartitionResponse
org.apache.kafka.clients.tools.
ProducerPerformance
org.apache.kafka.clients.producer.
ProducerRecord
org.apache.kafka.common.protocol.
Protocol
org.apache.kafka.common.protocol.
ProtoUtils
org.apache.kafka.common.metrics.
Quota
org.apache.kafka.common.metrics.stats.
Rate
(implements org.apache.kafka.common.metrics.
MeasurableStat
)
org.apache.kafka.common.record.
Record
org.apache.kafka.clients.producer.internals.
RecordAccumulator
org.apache.kafka.clients.producer.internals.
RecordAccumulator.ReadyCheckResult
org.apache.kafka.clients.producer.internals.
RecordAccumulator.RecordAppendResult
org.apache.kafka.clients.producer.internals.
RecordBatch
org.apache.kafka.clients.producer.
RecordMetadata
org.apache.kafka.common.metrics.stats.
SampledStat
(implements org.apache.kafka.common.metrics.
MeasurableStat
)
org.apache.kafka.common.metrics.stats.
Avg
org.apache.kafka.common.metrics.stats.
Count
org.apache.kafka.common.metrics.stats.
Max
org.apache.kafka.common.metrics.stats.
Min
org.apache.kafka.common.metrics.stats.
Percentiles
(implements org.apache.kafka.common.metrics.
CompoundStat
)
org.apache.kafka.common.metrics.stats.
Rate.SampledTotal
org.apache.kafka.common.metrics.stats.
SampledStat.Sample
org.apache.kafka.common.network.
Selector
(implements org.apache.kafka.common.network.
Selectable
)
org.apache.kafka.clients.producer.internals.
Sender
(implements java.lang.Runnable)
org.apache.kafka.common.metrics.
Sensor
org.apache.kafka.common.protocol.types.
Struct
org.apache.kafka.common.utils.
SystemTime
(implements org.apache.kafka.common.utils.
Time
)
java.lang.Thread (implements java.lang.Runnable)
org.apache.kafka.common.utils.
KafkaThread
java.lang.Throwable (implements java.io.Serializable)
java.lang.Exception
java.lang.RuntimeException
org.apache.kafka.common.record.
InvalidRecordException
org.apache.kafka.common.
KafkaException
org.apache.kafka.common.errors.
ApiException
org.apache.kafka.common.errors.
InvalidTopicException
org.apache.kafka.common.errors.
OffsetMetadataTooLarge
org.apache.kafka.common.errors.
RecordBatchTooLargeException
org.apache.kafka.common.errors.
RecordTooLargeException
org.apache.kafka.common.errors.
RetriableException
org.apache.kafka.common.errors.
CorruptRecordException
org.apache.kafka.common.errors.
InvalidMetadataException
org.apache.kafka.common.errors.
LeaderNotAvailableException
org.apache.kafka.common.errors.
NetworkException
org.apache.kafka.common.errors.
NotLeaderForPartitionException
org.apache.kafka.common.errors.
NotEnoughReplicasAfterAppendException
org.apache.kafka.common.errors.
NotEnoughReplicasException
org.apache.kafka.common.errors.
OffsetOutOfRangeException
org.apache.kafka.common.errors.
TimeoutException
org.apache.kafka.common.errors.
UnknownTopicOrPartitionException
org.apache.kafka.common.errors.
UnknownServerException
org.apache.kafka.clients.producer.
BufferExhaustedException
org.apache.kafka.common.config.
ConfigException
org.apache.kafka.common.metrics.
QuotaViolationException
org.apache.kafka.common.protocol.types.
SchemaException
org.apache.kafka.common.
TopicPartition
org.apache.kafka.common.metrics.stats.
Total
(implements org.apache.kafka.common.metrics.
MeasurableStat
)
org.apache.kafka.common.protocol.types.
Type
org.apache.kafka.common.protocol.types.
ArrayOf
org.apache.kafka.common.protocol.types.
Schema
org.apache.kafka.common.utils.
Utils
Interface Hierarchy
org.apache.kafka.clients.producer.
Callback
java.io.Closeable
org.apache.kafka.clients.consumer.
Consumer
org.apache.kafka.clients.producer.
Producer
org.apache.kafka.common.config.
ConfigDef.Validator
org.apache.kafka.common.
Configurable
org.apache.kafka.common.metrics.
MetricsReporter
org.apache.kafka.clients.consumer.
ConsumerRebalanceCallback
org.apache.kafka.common.metrics.stats.
Histogram.BinScheme
java.lang.Iterable<T>
org.apache.kafka.common.record.
Records
org.apache.kafka.clients.
KafkaClient
org.apache.kafka.common.metrics.
Measurable
org.apache.kafka.common.metrics.
MeasurableStat
(also extends org.apache.kafka.common.metrics.
Stat
)
org.apache.kafka.common.
Metric
org.apache.kafka.common.network.
Receive
org.apache.kafka.common.network.
Selectable
org.apache.kafka.common.network.
Send
org.apache.kafka.common.metrics.
Stat
org.apache.kafka.common.metrics.
CompoundStat
org.apache.kafka.common.metrics.
MeasurableStat
(also extends org.apache.kafka.common.metrics.
Measurable
)
org.apache.kafka.common.utils.
Time
Enum Hierarchy
java.lang.Object
java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
org.apache.kafka.common.protocol.
ApiKeys
org.apache.kafka.common.protocol.
Errors
org.apache.kafka.common.record.
CompressionType
org.apache.kafka.common.metrics.stats.
Percentiles.BucketSizing
org.apache.kafka.common.config.
ConfigDef.Type
org.apache.kafka.common.config.
ConfigDef.Importance
Overview
Package
Class
Tree
Deprecated
Index
Help
PREV NEXT
FRAMES
NO FRAMES
All Classes