vertx-lang-scala-docs_2.12 3.4.1 API < Back
 

# Packages

-  package root
  Definition Classes
    root
-  package io
  Definition Classes
    root
-  package vertx
  Definition Classes
    io
-  package scala
  Definition Classes
    vertx
-  package kafka
  Definition Classes
    scala
-  package client
  Definition Classes
    kafka
-  package producer
  Definition Classes
    client
- KafkaProducer
- KafkaProducerRecord
- RecordMetadata

o

io.vertx.scala.kafka.client.producer

# KafkaProducer 

###
Companion class KafkaProducer

#### object KafkaProducer

Linear Supertypes
AnyRef, Any
 
Ordering

1. Alphabetic
2. By Inheritance

Inherited

1. KafkaProducer
2. AnyRef
3. Any

1. Hide All
2. Show All

Visibility

1. Public
2. All

### 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
     @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

   Create a new KafkaProducer instance

   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

   Create a new KafkaProducer instance

   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`

   Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same `name`

   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`

    Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same `name`

    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
15.  def hashCode(): Int
    Definition Classes
      AnyRef → Any
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
19.  final def notifyAll(): Unit
    Definition Classes
      AnyRef
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
      @throws( ... )

### Inherited from AnyRef

### Inherited from Any

### Ungrouped