Event object class as passed to the EventCb callback. More...
#include <rdkafkacpp.h>
|
| enum | Type { EVENT_ERROR , EVENT_STATS , EVENT_LOG , EVENT_THROTTLE } |
| | Event type. More...
|
| |
| enum | Severity { EVENT_SEVERITY_EMERG = 0 , EVENT_SEVERITY_ALERT = 1 , EVENT_SEVERITY_CRITICAL = 2 , EVENT_SEVERITY_ERROR = 3 , EVENT_SEVERITY_WARNING = 4 , EVENT_SEVERITY_NOTICE = 5 , EVENT_SEVERITY_INFO = 6 , EVENT_SEVERITY_DEBUG = 7 } |
| | EVENT_LOG severities (conforms to syslog(3) severities)
|
| |
Event object class as passed to the EventCb callback.
◆ Type
Event type.
| Enumerator |
|---|
| EVENT_ERROR | Event is an error condition |
| EVENT_STATS | Event is a statistics JSON document |
| EVENT_LOG | Event is a log message |
| EVENT_THROTTLE | Event is a throttle level signaling from the broker |
◆ type()
| virtual Type RdKafka::Event::type | ( | | ) | const |
| pure virtual |
◆ err()
| virtual ErrorCode RdKafka::Event::err | ( | | ) | const |
| pure virtual |
- Returns
- Event error, if any.
◆ severity()
| virtual Severity RdKafka::Event::severity | ( | | ) | const |
| pure virtual |
- Returns
- Log severity level.
◆ fac()
| virtual std::string RdKafka::Event::fac | ( | | ) | const |
| pure virtual |
- Returns
- Log facility string.
◆ str()
| virtual std::string RdKafka::Event::str | ( | | ) | const |
| pure virtual |
- Returns
- Log message string.
EVENT_LOG: Log message string. EVENT_STATS: JSON object (as string).
◆ throttle_time()
| virtual int RdKafka::Event::throttle_time | ( | | ) | const |
| pure virtual |
- Returns
- Throttle time in milliseconds.
◆ broker_name()
| virtual std::string RdKafka::Event::broker_name | ( | | ) | const |
| pure virtual |
- Returns
- Throttling broker's name.
◆ broker_id()
| virtual int RdKafka::Event::broker_id | ( | | ) | const |
| pure virtual |
- Returns
- Throttling broker's id.
◆ fatal()
| virtual bool RdKafka::Event::fatal | ( | | ) | const |
| pure virtual |
The documentation for this class was generated from the following file: