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 AsyncProducerInterruptedException extends RuntimeException

  4. class AsyncProducerStats[T] extends AsyncProducerStatsMBean

  5. trait AsyncProducerStatsMBean extends AnyRef

  6. trait CallbackHandler[T] extends AnyRef

    Callback handler APIs for use in the async producer.

  7. trait EventHandler[T] extends AnyRef

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

  8. class IllegalQueueStateException extends RuntimeException

    Indicates that the given config parameter has invalid value

  9. class MissingConfigException extends RuntimeException

  10. class QueueClosedException extends RuntimeException

  11. class QueueFullException extends RuntimeException

  12. class QueueItem[T] extends AnyRef

Value Members

  1. object AsyncProducer extends AnyRef