Define CHECK_KAFKA
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.