kafka.producer

async

package async

Visibility
  1. Public
  2. All

Type Members

  1. class AsyncProducerConfig extends SyncProducerConfig with AsyncProducerConfigShared

  2. trait AsyncProducerConfigShared extends AnyRef

  3. class AsyncProducerStats[T] extends AsyncProducerStatsMBean

  4. trait AsyncProducerStatsMBean extends AnyRef

  5. trait CallbackHandler[T] extends AnyRef

    Callback handler APIs for use in the async producer.

  6. trait EventHandler[T] extends AnyRef

    Handler that dispatches the batched data from the queue of the asynchronous producer.

  7. class MissingConfigException extends RuntimeException

  8. class QueueClosedException extends RuntimeException

  9. class QueueFullException extends RuntimeException

  10. class QueueItem[T] extends AnyRef

Value Members

  1. object AsyncProducer extends AnyRef