package producer
Ordering
- Alphabetic
Visibility
- Public
- All
Type Members
- trait AsProducerRecord[-A] extends AnyRef
A typeclass to allow the publication of any record 'A' which can be converted into a producer record
- final case class PromiseCallback(promise: Promise[RecordMetadata] = Promise[RecordMetadata]()) extends Callback with Product with Serializable
- final class RichKafkaProducer[K, V] extends AutoCloseable with StrictLogging
Value Members
- object AsProducerRecord
- object LoggingCallback extends Callback with StrictLogging
- object RichKafkaProducer extends StrictLogging