Value Members

1.  final def !=(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

2.  final def ##(): Int

   Definition Classes

   AnyRef → Any

3.  final def ==(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

4.  def apply[K, V](asJava: kafka.client.producer.KafkaProducer[_, _])(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[K], arg1: scala.reflect.api.JavaUniverse.TypeTag[V]): KafkaProducer[K, V]
5.  final def asInstanceOf[T0]: T0

   Definition Classes

   Any

6.  def clone(): AnyRef

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @native() @throws( ... )

7.  def create[K, V](vertx: Vertx, config: Map[String, String], keyType: Class[K], valueType: Class[V])(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[K], arg1: scala.reflect.api.JavaUniverse.TypeTag[V]): KafkaProducer[K, V]

   Create a new KafkaProducer instance * @param vertx Vert.x instance to use

   Create a new KafkaProducer instance * @param vertx Vert.x instance to use

   config

   Kafka producer configuration

   keyType

   class type for the key serialization

   valueType

   class type for the value serialization

   returns

   an instance of the KafkaProducer

8.  def create[K, V](vertx: Vertx, config: Map[String, String])(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[K], arg1: scala.reflect.api.JavaUniverse.TypeTag[V]): KafkaProducer[K, V]

   Create a new KafkaProducer instance * @param vertx Vert.x instance to use

   Create a new KafkaProducer instance * @param vertx Vert.x instance to use

   config

   Kafka producer configuration

   returns

   an instance of the KafkaProducer

9.  def createShared[K, V](vertx: Vertx, name: String, config: Map[String, String], keyType: Class[K], valueType: Class[V])(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[K], arg1: scala.reflect.api.JavaUniverse.TypeTag[V]): KafkaProducer[K, V]

   Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same name * @param vertx Vert.x instance to use

   Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same name * @param vertx Vert.x instance to use

   name

   the producer name to identify it

   config

   Kafka producer configuration

   keyType

   class type for the key serialization

   valueType

   class type for the value serialization

   returns

   an instance of the KafkaProducer

10.  def createShared[K, V](vertx: Vertx, name: String, config: Map[String, String])(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[K], arg1: scala.reflect.api.JavaUniverse.TypeTag[V]): KafkaProducer[K, V]

    Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same name * @param vertx Vert.x instance to use

    Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same name * @param vertx Vert.x instance to use

    name

    the producer name to identify it

    config

    Kafka producer configuration

    returns

    an instance of the KafkaProducer

11.  final def eq(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

12.  def equals(arg0: Any): Boolean

    Definition Classes

    AnyRef → Any

13.  def finalize(): Unit

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

14.  final def getClass(): Class[_]

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

15.  def hashCode(): Int

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

16.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

17.  final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

18.  final def notify(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

19.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

20.  final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes

    AnyRef

21.  def toString(): String

    Definition Classes

    AnyRef → Any

22.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

23.  final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

24.  final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @native() @throws( ... )