Defined in File kafka_source.cpp
- CHECK_KAFKA(command, expected, msg)
Checks the error code returned by an RDKafka expression (command) against an expected code (usually RdKafka::ERR_NO_ERROR), and logs an error otherwise.
Defined in File kafka_source.cpp
Checks the error code returned by an RDKafka expression (command) against an expected code (usually RdKafka::ERR_NO_ERROR), and logs an error otherwise.