Package org.apache.kafka.clients.producer

  • Interface Summary
    Interface Description
    Callback
    A callback interface that the user can implement to allow code to execute when the request is complete.
    Partitioner
    Partitioner Interface
    Producer<K,​V>
    The interface for the KafkaProducer
    ProducerInterceptor<K,​V>
    A plugin interface that allows you to intercept (and possibly mutate) the records received by the producer before they are published to the Kafka cluster.
  • Class Summary
    Class Description
    KafkaProducer<K,​V>
    A Kafka client that publishes records to the Kafka cluster.
    MockProducer<K,​V>
    A mock of the producer interface you can use for testing code that uses Kafka.
    ProducerConfig
    Configuration for the Kafka Producer.
    ProducerRecord<K,​V>
    A key/value pair to be sent to Kafka.
    RecordMetadata
    The metadata for a record that has been acknowledged by the server
    RoundRobinPartitioner
    The "Round-Robin" partitioner This partitioning strategy can be used when user wants to distribute the writes to all partitions equally.
    UniformStickyPartitioner
    The partitioning strategy: If a partition is specified in the record, use it Otherwise choose the sticky partition that changes when the batch is full.
  • Exception Summary
    Exception Description
    BufferExhaustedException
    This exception is thrown if the producer cannot allocate memory for a record within max.block.ms due to the buffer being too full.