Classes, interfaces and traits

AdminUtils

Provides a wrapper around important methods in Kafka's AdminUtils, namely

« More »

Config

A configuration object containing the configuration entries for a resource

« More »

ConfigEntry

A class representing a configuration entry containing name, value and additional metadata

« More »

ConfigSynonym

Class representing a configuration synonym of a @see \io\vertx\jphp\kafka\admin\ConfigEntry

« More »

ConsumerGroupDescription

A detailed description of a single consumer group in the cluster

« More »

ConsumerGroupListing

A listing of a consumer group in the cluster.

« More »

KafkaAdminClient

Vert.x Kafka Admin client implementation

« More »

MemberAssignment

A description of the assignments of a specific group member

« More »

MemberDescription

A detailed description of a single group instance in the cluster

« More »

NewTopic

A new topic to be created

« More »

TopicDescription

A detailed description of a single topic in the cluster

« More »

Classes, interfaces and traits

ConfigResource

A class representing resources that have configuration

« More »

Node

Information about a Kafka cluster node

« More »

PartitionInfo

Information about a specific Kafka topic partition

« More »

TopicPartition

Represent information related to a partition for a topic

« More »

TopicPartitionInfo

A class containing leadership, replicas and ISR information for a topic partition.

« More »

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 »

Classes, interfaces and traits

KafkaHeader

Vert.x Kafka producer record header.

« More »

KafkaProducer

Vert.x Kafka producer.

The provides global control over writing a record.

« More »

KafkaProducerRecord

Vert.x Kafka producer record.

« More »

RecordMetadata

Metadata related to a Kafka record

« More »