vertx / io.vertx.kafka.client.consumer / KafkaReadStream / create

# create

`open static fun <K : Any, V : Any> create(vertx: Vertx, config: Properties): KafkaReadStream<K, V>`
`open static fun <K : Any, V : Any> create(vertx: Vertx, config: MutableMap<String, Any>): KafkaReadStream<K, V>`

Create a new KafkaReadStream instance

### Parameters

`vertx` - Vert.x instance to use

`config` - Kafka consumer configuration

Return
an instance of the KafkaReadStream

`open static fun <K : Any, V : Any> create(vertx: Vertx, config: Properties, keyType: Class<K>, valueType: Class<V>): KafkaReadStream<K, V>`
`open static fun <K : Any, V : Any> create(vertx: Vertx, config: MutableMap<String, Any>, keyType: Class<K>, valueType: Class<V>): KafkaReadStream<K, V>`

Create a new KafkaReadStream instance

### Parameters

`vertx` - Vert.x instance to use

`config` - Kafka consumer configuration

`keyType` - class type for the key deserialization

`valueType` - class type for the value deserialization

Return
an instance of the KafkaReadStream

`open static fun <K : Any, V : Any> create(vertx: Vertx, consumer: Consumer<K, V>): KafkaReadStream<K, V>`

Create a new KafkaReadStream instance

### Parameters

`vertx` - Vert.x instance to use

`consumer` - native Kafka consumer instance

Return
an instance of the KafkaReadStream