producer

Type Members

trait BaseProducer extends AnyRef
class BrokerPartitionInfo extends Logging
class ByteArrayPartitioner extends Partitioner
class DefaultPartitioner extends Partitioner
case class KeyedMessage[K, V](topic: String, key: K, partKey: Any, message: V) extends Product with Serializable

A topic, key, and value.
A topic, key, and value. If a partition key is provided it will override the key for the purpose of partitioning but will not be stored.
class NewShinyProducer extends BaseProducer
class OldProducer extends BaseProducer
case class PartitionAndLeader(topic: String, partitionId: Int, leaderBrokerIdOpt: Option[Int]) extends Product with Serializable
trait Partitioner extends AnyRef

A partitioner controls the mapping between user-provided keys and kafka partitions.
A partitioner controls the mapping between user-provided keys and kafka partitions. Users can implement a custom partitioner to change this mapping.
Implementations will be constructed via reflection and are required to have a constructor that takes a single VerifiableProperties instance--this allows passing configuration properties into the partitioner implementation.
class Producer[K, V] extends Logging
class ProducerClosedException extends RuntimeException
class ProducerConfig extends AsyncProducerConfig with SyncProducerConfigShared
class ProducerPool extends Logging
class ProducerRequestMetrics extends KafkaMetricsGroup
class ProducerRequestStats extends AnyRef

Tracks metrics of requests made by a given producer client to all brokers.
class ProducerStats extends KafkaMetricsGroup
class ProducerTopicMetrics extends KafkaMetricsGroup

Annotations
@threadsafe()
class ProducerTopicStats extends AnyRef

Tracks metrics for each topic the given producer client has produced data to.
class SyncProducer extends Logging

Annotations
@threadsafe()
class SyncProducerConfig extends SyncProducerConfigShared
trait SyncProducerConfigShared extends AnyRef

Value Members

object ProducerConfig extends Config
object ProducerPool
object ProducerRequestStatsRegistry

Stores the request stats information of each producer client in a (clientId -> ProducerRequestStats) map.
object ProducerStatsRegistry

Stores metrics of serialization and message sending activity of each producer client in a (clientId -> ProducerStats) map.
object ProducerTopicStatsRegistry

Stores the topic stats information of each producer client in a (clientId -> ProducerTopicStats) map.
object SyncProducer
object SyncProducerConfig
package async

package producer

Type Members

trait BaseProducer extends AnyRef

class BrokerPartitionInfo extends Logging

class ByteArrayPartitioner extends Partitioner

class DefaultPartitioner extends Partitioner

case class KeyedMessage[K, V](topic: String, key: K, partKey: Any, message: V) extends Product with Serializable

class NewShinyProducer extends BaseProducer

class OldProducer extends BaseProducer

case class PartitionAndLeader(topic: String, partitionId: Int, leaderBrokerIdOpt: Option[Int]) extends Product with Serializable

trait Partitioner extends AnyRef

class Producer[K, V] extends Logging

class ProducerClosedException extends RuntimeException

class ProducerConfig extends AsyncProducerConfig with SyncProducerConfigShared

class ProducerPool extends Logging

class ProducerRequestMetrics extends KafkaMetricsGroup

class ProducerRequestStats extends AnyRef

class ProducerStats extends KafkaMetricsGroup

class ProducerTopicMetrics extends KafkaMetricsGroup

class ProducerTopicStats extends AnyRef

class SyncProducer extends Logging

class SyncProducerConfig extends SyncProducerConfigShared

trait SyncProducerConfigShared extends AnyRef

Value Members

object ProducerConfig extends Config

object ProducerPool

object ProducerRequestStatsRegistry

object ProducerStatsRegistry

object ProducerTopicStatsRegistry

object SyncProducer

object SyncProducerConfig

package async

Ungrouped