Class Message¶
Class \RdKafka\Message
Properties¶
brokerId¶
public int brokerId
err¶
public int err
headers¶
public array headers
key¶
public ?string key
latency¶
public int latency
len¶
public ?int len
offset¶
public int offset
opaque¶
public mixed|null opaque
partition¶
public int partition
payload¶
public ?string payload
status¶
public int status
timestamp¶
public int timestamp
timestampType¶
public int timestampType
topic_name¶
public ?string topic_name
Methods¶
__construct()¶
public __construct (
\FFI\CData $nativeMessage
):
- Parameters
- nativeMessage
\FFI\CData
errstr()¶
public errstr ( ): string
- Returns
string
Test Coverage 💛¶
- 💛 Lines: 89.09% (49 / 55)
- ❤️ Methods: 33.33% (1 / 3)