Packages

object KafkaConsumer

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. KafkaConsumer
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

  1. def apply[K, V](asJava: kafka.client.consumer.KafkaConsumer[_, _])(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[K], arg1: scala.reflect.api.JavaUniverse.TypeTag[V]): KafkaConsumer[K, V]
  2. 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]): KafkaConsumer[K, V]

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

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

    config

    Kafka consumer configuration

    keyType

    class type for the key deserialization

    valueType

    class type for the value deserialization

    returns

    an instance of the KafkaConsumer

  3. 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]): KafkaConsumer[K, V]

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

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

    config

    Kafka consumer configuration

    returns

    an instance of the KafkaConsumer