ClientCommon.h

#pragma once
 
#include <chrono>
#include <kafka/Project.h>
 
#include <kafka/Error.h>
 
#include <functional>
 
 
namespace KAFKA_API { namespace clients {
 
    using LogCallback   = std::function<void(int, const char*, int, const char* msg)>;
 
    using ErrorCallback = std::function<void(const Error&)>;
 
    using StatsCallback = std::function<void(const std::string&)>;
 
    struct SaslOauthbearerToken
    {
        using KeyValuePairs = std::map<std::string, std::string>;
 
        std::string               value;
        std::chrono::milliseconds mdLifetime{};
        std::string               mdPrincipalName;
        KeyValuePairs             extensions;
    };
 
    using OauthbearerTokenRefreshCallback = std::function<SaslOauthbearerToken(const std::string&)>;
 
} } // end of KAFKA_API::clients