例子 include"rdkafkacpp.h" include<chrono> include<time.h> include<sstream> include<iomanip> include<iostream> voidHandleMessage(RdKafka::Message&message,voidopaque) { switch(message.err()){ caseRdKafka::ERR__TIMED_OUT: std::cout<<"RdKafka::ERR__TIMED_OUT"...