ClientConfig.h

#pragma once
 
#include <kafka/Project.h>
 
#include <kafka/Properties.h>
 
 
namespace KAFKA_API { namespace clients {
 
class Config: public Properties
{
public:
    Config() = default;
    Config(const Config&) = default;
    explicit Config(const PropertiesMap& kvMap): Properties(kvMap) {}
 
    static const constexpr char* ENABLE_MANUAL_EVENTS_POLL      = "enable.manual.events.poll";
 
    static const constexpr char* LOG_CB                         = "log_cb";
 
    static const constexpr char* ERROR_CB                       = "error_cb";
 
    static const constexpr char* STATS_CB                       = "stats_cb";
 
    static const constexpr char* OAUTHBEARER_TOKEN_REFRESH_CB   = "oauthbearer_token_refresh_cb";
 
    static const constexpr char* INTERCEPTORS                   = "interceptors";
 
    static const constexpr char* BOOTSTRAP_SERVERS         = "bootstrap.servers";
 
    static const constexpr char* CLIENT_ID                 = "client.id";
 
    static const constexpr char* LOG_LEVEL                 = "log_level";
 
    static const constexpr char* SOCKET_TIMEOUT_MS         = "socket.timeout.ms";
 
    static const constexpr char* SECURITY_PROTOCOL            = "security.protocol";
 
    static const constexpr char* SASL_MECHANISM               = "sasl.mechanisms";
 
    static const constexpr char* SASL_USERNAME                = "sasl.username";
 
    static const constexpr char* SASL_PASSWORD                = "sasl.password";
 
    static const constexpr char* SASL_KERBEROS_KINIT_CMD      = "sasl.kerberos.kinit.cmd";
 
    static const constexpr char* SASL_KERBEROS_SERVICE_NAME   = "sasl.kerberos.service.name";
 
    static const constexpr char* SASL_OAUTHBEARER_METHOD              = "sasl.oauthbearer.method";
 
    static const constexpr char* SASL_OAUTHBEARER_CLIENT_ID           = "sasl.oauthbearer.client.id";
 
    static const constexpr char* SASL_OAUTHBEARER_CLIENT_SECRET       = "sasl.oauthbearer.client.secret";
 
    static const constexpr char* SASL_OAUTHBEARER_EXTENSIONS          = "sasl.oauthbearer.extensions";
 
    static const constexpr char* SASL_OAUTHBEARER_SCOPE               = "sasl.oauthbearer.scope";
 
    static const constexpr char* SASL_OAUTHBEARER_TOKEN_ENDPOINT_URL  = "sasl.oauthbearer.token.endpoint.url";
 
    static const constexpr char* SASL_OAUTHBEARER_CONFIG              = "sasl.oauthbearer.config";
 
    static const constexpr char* ENABLE_SASL_OAUTHBEARER_UNSECURE_JWT = "enable.sasl.oauthbearer.unsecure.jwt";
};
 
} } // end of KAFKA_API::clients