KafkaProducerRecord

Vert.x Kafka producer record.

package

Default

Methods

__construct

__construct() 

Add an header to this record.

addHeader( $arg0,  $arg1 = null) : $this

param $header [KafkaHeader] the header addHeader($header)

Like @see \io\vertx\jphp\kafka\client\producer\KafkaProducerRecord::addHeader but with a key/value pair

param $key [string] param $value [string] addHeader($key, $value)

Like @see \io\vertx\jphp\kafka\client\producer\KafkaProducerRecord::addHeader but with a key/value pair

param $key [string] param $value [Buffer] addHeader($key, $value)

Arguments

$arg0

string | KafkaHeader

$arg1

Buffer | string

Response

$this

current KafkaProducerRecord instance

Add a list of headers to this record.

addHeaders( $arg0) : $this

Arguments

$arg0

array

Response

$this

current KafkaProducerRecord instance

Create a concrete instance of a Vert.x producer record

create( $arg0,  $arg1,  $arg2 = null,  $arg3 = null,  $arg4 = null) : \io\vertx\jphp\kafka\client\producer\KafkaProducerRecord<K,V>
static

param $topic [string] the topic this record is being sent to param $value [mixed] the value create($topic, $value)

Create a concrete instance of a Vert.x producer record

param $topic [string] the topic this record is being sent to param $key [mixed] the key (or null if no key is specified) param $value [mixed] the value create($topic, $key, $value)

Create a concrete instance of a Vert.x producer record

param $topic [string] the topic this record is being sent to param $key [mixed] the key (or null if no key is specified) param $value [mixed] the value param $timestamp [integer] the timestamp of this record param $partition [integer] the partition to which the record will be sent (or null if no partition was specified) create($topic, $key, $value, $timestamp, $partition)

Arguments

$arg0

string

$arg1

mixed

$arg2

mixed

$arg3

integer

$arg4

integer

Response

\io\vertx\jphp\kafka\client\producer\KafkaProducerRecord

Vert.x producer record

headers

headers() : array

Response

array

the headers of this record

key

key() : mixed

Response

mixed

the key (or null if no key is specified)

partition

partition() : integer

Response

integer

the partition to which the record will be sent (or null if no partition was specified)

timestamp

timestamp() : integer

Response

integer

the timestamp of this record

topic

topic() : string

Response

string

the topic this record is being sent to

value

value() : mixed

Response

mixed

the value