Event

Event object class as passed to the EventCb callback.

struct Event {

this(Type type, ErrorCode err, Severity severity, char* fac, char* str);

this(Type type);

package nothrow @nogc

package nothrow @nogc

ErrorCode err_;

package nothrow @nogc

Severity severity_;

package nothrow @nogc

const(char)[] fac_;

package nothrow @nogc

const(char)[] str_;

package nothrow @nogc

package nothrow @nogc

int throttle_time_;

Type type [@property getter];

ErrorCode err [@property getter];

Severity severity [@property getter];

const(char)[] fac [@property getter];

const(char)[] str [@property getter];

int throttleTime [@property getter];

const(char)[] brokerName [@property getter];

int brokerId [@property getter];

}

Constructors

this this(Type type, ErrorCode err, Severity severity, char* fac, char* str): Undocumented in source.
this this(Type type): Undocumented in source.

Members

Enums

Severity enum Severity: LOG severities (conforms to syslog(3) severities)
Type enum Type: Event type

Properties

brokerId int brokerId [@property getter]: Throttling broker's id. Note: Applies to throttle event type.
brokerName const(char)[] brokerName [@property getter]: Throttling broker's name. Note: Applies to throttle event type.
err ErrorCode err [@property getter]: Event error, if any. Note: Applies to all event types except throttle
fac const(char)[] fac [@property getter]: Log facility string. Note: Applies to LOG event type.
severity Severity severity [@property getter]: Log severity level. Note: Applies to LOG event type.
str const(char)[] str [@property getter]: Log message string.
throttleTime int throttleTime [@property getter]: throttle time in milliseconds. Note: Applies to throttle event type.
type Type type [@property getter]: The event type Note: Applies to all event types

Variables

err_ ErrorCode err_;: Undocumented in source.
fac_ const(char)[] fac_;: Undocumented in source.
id_ int id_;: Undocumented in source.
severity_ Severity severity_;: Undocumented in source.
str_ const(char)[] str_;: Undocumented in source.
throttle_time_ int throttle_time_;: Undocumented in source.
type_ Type type_;: Undocumented in source.

Meta

Source

See Implementation

rdkafkad modules

aliases

enums

ErrorCode

functions

manifest constants

RD_KAFKA_VERSION

structs