Utility.h

#pragma once
 
#include <kafka/Project.h>
 
#include <librdkafka/rdkafka.h>
 
#include <chrono>
#include <iomanip>
#include <random>
#include <sstream>
#include <string>
#include <time.h>
 
 
namespace KAFKA_API { namespace utility {
 
inline std::string getLocalTimeString(const std::chrono::system_clock::time_point& timePoint)
{
    auto time = std::chrono::system_clock::to_time_t(timePoint);
    std::tm tmBuf = {};
 
#if !defined(WIN32)
    localtime_r(&time, &tmBuf);
#else
    localtime_s(&tmBuf, &time);
#endif
 
    std::ostringstream oss;
    oss << std::put_time(&tmBuf, "%F %T") <<  "." << std::setfill('0') << std::setw(6)
        << std::chrono::duration_cast<std::chrono::microseconds>(timePoint.time_since_epoch()).count() % 1000000;
 
    return oss.str();
}
 
inline std::string getCurrentTime()
{
    return getLocalTimeString(std::chrono::system_clock::now());
}
 
inline std::string getRandomString()
{
    using namespace std::chrono;
 
    const std::uint32_t timestamp = static_cast<std::uint32_t>(duration_cast<nanoseconds>(system_clock::now().time_since_epoch()).count());
 
    std::random_device r;
    std::default_random_engine e(r());
    std::uniform_int_distribution<std::uint64_t> uniform_dist(0, 0xFFFFFFFF);
    const std::uint64_t rand = uniform_dist(e);
 
    std::ostringstream oss;
    oss << std::setfill('0') << std::setw(sizeof(std::uint32_t) * 2) << std::hex << timestamp << "-" << rand;
    return oss.str();
}
 
inline std::string getLibRdKafkaVersion()
{
    return rd_kafka_version_str();
}
 
inline int getLibRdKafkaThreadCount()
{
    return rd_kafka_thread_cnt();
}
 
} } // end of KAFKA_API::utility