Class Hierarchy
- java.lang.Object
- org.apache.kafka.common.config.AbstractConfig
- org.apache.kafka.clients.producer.ProducerConfig
- org.apache.kafka.clients.producer.KafkaProducer<K,V> (implements org.apache.kafka.clients.producer.Producer<K,V>)
- org.apache.kafka.clients.producer.MockProducer<K,V> (implements org.apache.kafka.clients.producer.Producer<K,V>)
- org.apache.kafka.clients.producer.ProducerRecord<K,V>
- org.apache.kafka.clients.producer.RecordMetadata
- org.apache.kafka.clients.producer.RoundRobinPartitioner (implements org.apache.kafka.clients.producer.Partitioner)
- java.lang.Throwable (implements java.io.Serializable)
- java.lang.Exception
- java.lang.RuntimeException
- org.apache.kafka.common.KafkaException
- org.apache.kafka.common.errors.ApiException
- org.apache.kafka.common.errors.RetriableException
- org.apache.kafka.common.errors.TimeoutException
- org.apache.kafka.clients.producer.BufferExhaustedException
- org.apache.kafka.common.errors.TimeoutException
- org.apache.kafka.common.errors.RetriableException
- org.apache.kafka.common.errors.ApiException
- org.apache.kafka.common.KafkaException
- java.lang.RuntimeException
- java.lang.Exception
- org.apache.kafka.clients.producer.UniformStickyPartitioner (implements org.apache.kafka.clients.producer.Partitioner)
- org.apache.kafka.common.config.AbstractConfig
Interface Hierarchy
- java.lang.AutoCloseable
- java.io.Closeable
- org.apache.kafka.clients.producer.Partitioner (also extends org.apache.kafka.common.Configurable)
- org.apache.kafka.clients.producer.Producer<K,V>
- java.io.Closeable
- org.apache.kafka.clients.producer.Callback
- org.apache.kafka.common.Configurable
- org.apache.kafka.clients.producer.Partitioner (also extends java.io.Closeable)
- org.apache.kafka.clients.producer.ProducerInterceptor<K,V>