在librdkafka中，dr_cb在produce()线程或poll()线程上执行

void delivery_report_callback(rd_kafka_t *rk, const rd_kafka_message_t *rkmessage, void *opaque) {
    if (rkmessage->err) {
        printf("Message delivery failed: %s\n", rd_kafka_err2str(rkmessage->err));
    } else {
        printf("Message delivered to topic %s [%d] at offset %ld\n",
               rd_kafka_topic_name(rkmessage->rkt),
               rkmessage->partition, rkmessage->offset);
    }
}

int main() {
    // 创建Kafka生产者
    rd_kafka_t *rk = rd_kafka_new(...);

    // 设置消息发送结果回调函数
    rd_kafka_conf_set_dr_msg_cb(conf, delivery_report_callback);

    // 发送消息
    rd_kafka_produce(...);

    // 等待消息发送结果回调
    rd_kafka_poll(rk, 0);

    // 销毁Kafka生产者
    rd_kafka_destroy(rk);

    return 0;
}