Classes, interfaces and traits

KafkaConsumer

Vert.x Kafka consumer.

You receive Kafka records by providing a @see \io\vertx\jphp\kafka\client\consumer\KafkaConsumer::handler. As messages arrive the handler will be called with the records.

The @see \io\vertx\jphp\kafka\client\consumer\KafkaConsumer::pause and @see \io\vertx\jphp\kafka\client\consumer\KafkaConsumer::resume provides global control over reading the records from the consumer.

The @see \io\vertx\jphp\kafka\client\consumer\KafkaConsumer::pause and @see \io\vertx\jphp\kafka\client\consumer\KafkaConsumer::resume provides finer grained control over reading records for specific Topic/Partition, these are Kafka's specific operations.

« More »

KafkaConsumerRecord

Vert.x Kafka consumer record

« More »

KafkaConsumerRecords

Vert.x Kafka consumer records

« More »

OffsetAndMetadata

Provide additional metadata when an offset is committed

« More »

OffsetAndTimestamp

Represent information related to a Offset with timestamp information

« More »