Vert.x Kafka producer record.
package |
Default |
---|
__construct()
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)
string | KafkaHeader
Buffer | string
$this
current KafkaProducerRecord instance
addHeaders( $arg0) : $this
array
$this
current KafkaProducerRecord instance
create( $arg0, $arg1, $arg2 = null, $arg3 = null, $arg4 = null) : \io\vertx\jphp\kafka\client\producer\KafkaProducerRecord<K,V>
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)
string
mixed
mixed
integer
integer
\io\vertx\jphp\kafka\client\producer\KafkaProducerRecord
Vert.x producer record
headers() : array
array
the headers of this record
key() : mixed
mixed
the key (or null if no key is specified)
partition() : integer
integer
the partition to which the record will be sent (or null if no partition was specified)
topic() : string
string
the topic this record is being sent to
value() : mixed
mixed
the value