KafkaAdminClient

Vert.x Kafka Admin client implementation

package

Default

Methods

__construct

__construct() 

Create a new KafkaAdminClient instance

create( $arg0,  $arg1) : \io\vertx\jphp\kafka\admin\KafkaAdminClient
static

Arguments

$arg0

Vertx

$arg1

array

Response

\io\vertx\jphp\kafka\admin\KafkaAdminClient

an instance of the KafkaAdminClient

Creates a batch of new Kafka topics

createTopics( $arg0,  $arg1) : void

Arguments

$arg0

array

$arg1

callable

Deletes a batch of Kafka topics

deleteTopics( $arg0,  $arg1) : void

Arguments

$arg0

array

$arg1

callable

Get the the consumer groups available in the cluster with the default options

listConsumerGroups( $arg0) : void

Arguments

$arg0

callable

List the topics available in the cluster with the default options.

listTopics( $arg0) : void

Arguments

$arg0

callable