1. class
  2. SimpleKafkaClient
  3. \
  4. ProducerTopic

ProducerTopic

class ProducerTopic extends Topic (View source)

Methods

string
getName()

No description

from  Topic
void
produce(int $partition, int $msgFlags, string|null $payload = null, string|null $key = null)

No description

void
producev(int $partition, int $msgFlags, string|null $payload = null, string|null $key = null, array|null $headers = null, int|null $timestampMs = null)

No description

Details

in Topic at line 11
string getName()

No description

Return Value

string

at line 30
void produce(int $partition, int $msgFlags, string|null $payload = null, string|null $key = null)

No description

Parameters

int $partition
int $msgFlags
string|null $payload
string|null $key

Return Value

void

Exceptions

Exception

at line 41
void producev(int $partition, int $msgFlags, string|null $payload = null, string|null $key = null, array|null $headers = null, int|null $timestampMs = null)

No description

Parameters

int $partition
int $msgFlags
string|null $payload
string|null $key
array|null $headers
int|null $timestampMs

Return Value

void

Exceptions

Exception