我印象中,kafka 0.8.2没有回调吧。
进程一直在运行,里面有个定时器一直轮询kafka句柄,几个消息很快发过去后,回调都会过来,但是回调函数带的消息号码都是最新的那个消息号码,请问大神,这个问题需要在哪里设置啊,发送函数rd_kafka_produce(rd_kafka_topic_t rkt, int32_t partitition, int msgflags, void payload, size_t len, const void key, size_t keylen, void msg_opaque);用msg_opaque来传递给回调函数消息号码