-
-
Notifications
You must be signed in to change notification settings - Fork 2
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
35 changed files
with
870 additions
and
505 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,46 @@ | ||
| #pragma once | ||
|
|
||
| #include <kafka/Project.h> | ||
|
|
||
| #include <kafka/Error.h> | ||
|
|
||
| #include <functional> | ||
|
|
||
|
|
||
| namespace KAFKA_API { namespace clients { | ||
|
|
||
| /** | ||
| * Callback type for logging. | ||
| */ | ||
| using LogCallback = std::function<void(int, const char*, int, const char* msg)>; | ||
|
|
||
| /** | ||
| * Callback type for error notification. | ||
| */ | ||
| using ErrorCallback = std::function<void(const Error&)>; | ||
|
|
||
| /** | ||
| * Callback type for statistics info dumping. | ||
| */ | ||
| using StatsCallback = std::function<void(const std::string&)>; | ||
|
|
||
| /** | ||
| * SASL OAUTHBEARER token info. | ||
| */ | ||
| struct SaslOauthbearerToken | ||
| { | ||
| using KeyValuePairs = std::map<std::string, std::string>; | ||
|
|
||
| std::string value; | ||
| std::chrono::microseconds mdLifetime{}; | ||
| std::string mdPrincipalName; | ||
| KeyValuePairs extensions; | ||
| }; | ||
|
|
||
| /** | ||
| * Callback type for OAUTHBEARER token refresh. | ||
| */ | ||
| using OauthbearerTokenRefreshCallback = std::function<SaslOauthbearerToken(const std::string&)>; | ||
|
|
||
| } } // end of KAFKA_API::clients | ||
|
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,172 @@ | ||
| #pragma once | ||
|
|
||
| #include <kafka/Project.h> | ||
|
|
||
| #include <kafka/Properties.h> | ||
|
|
||
|
|
||
| namespace KAFKA_API { namespace clients { | ||
|
|
||
| /** | ||
| * Configuration for Kafka clients.. | ||
| */ | ||
| class Config: public Properties | ||
| { | ||
| public: | ||
| Config() = default; | ||
| Config(const Config&) = default; | ||
| explicit Config(const PropertiesMap& kvMap): Properties(kvMap) {} | ||
|
|
||
| /** | ||
| * To poll the events manually (otherwise, it would be done with a background polling thread). | ||
| * Note: Once it's enabled, the interface `pollEvents()` should be manually called, in order to trigger | ||
| * 1) The offset-commit callbacks, for consumers. | ||
| * 2) The message-delivery callbacks, for producers. | ||
| */ | ||
| static const constexpr char* ENABLE_MANUAL_EVENTS_POLL = "enable.manual.events.poll"; | ||
|
|
||
| /** | ||
| * Log callback. | ||
| * Type: `std::function<void(int, const char*, int, const char* msg)>` | ||
| */ | ||
| static const constexpr char* LOG_CB = "log_cb"; | ||
|
|
||
| /** | ||
| * Log callback. | ||
| * Type: `std::function<void(const Error&)>` | ||
| */ | ||
| static const constexpr char* ERROR_CB = "error_cb"; | ||
|
|
||
| /** | ||
| * Statistics callback. | ||
| * Type: `std::function<void(const std::string&)>` | ||
| */ | ||
| static const constexpr char* STATS_CB = "stats_cb"; | ||
|
|
||
| /** | ||
| * OAUTHBEARER token refresh callback. | ||
| * Type: `std::function<SaslOauthbearerToken(const std::string&)>` | ||
| */ | ||
| static const constexpr char* OAUTHBEARER_TOKEN_REFRESH_CB = "oauthbearer_token_refresh_cb"; | ||
|
|
||
| /** | ||
| * Interceptors for thread start/exit, brokers' state change, etc. | ||
| * Type: `Interceptors` | ||
| */ | ||
| static const constexpr char* INTERCEPTORS = "interceptors"; | ||
|
|
||
| /** | ||
| * The string contains host:port pairs of brokers (splitted by ",") that the consumer will use to establish initial connection to the Kafka cluster. | ||
| * Note: It's mandatory. | ||
| */ | ||
| static const constexpr char* BOOTSTRAP_SERVERS = "bootstrap.servers"; | ||
|
|
||
| /** | ||
| * Client identifier. | ||
| */ | ||
| static const constexpr char* CLIENT_ID = "client.id"; | ||
|
|
||
| /** | ||
| * Log level (syslog(3) levels). | ||
| */ | ||
| static const constexpr char* LOG_LEVEL = "log_level"; | ||
|
|
||
| /** | ||
| * A comma-separated list of debug contexts to enable. | ||
| */ | ||
| static const constexpr char* DEBUG = "debug"; | ||
|
|
||
| /** | ||
| * Timeout for network requests. | ||
| * Default value: 60000 | ||
| */ | ||
| static const constexpr char* SOCKET_TIMEOUT_MS = "socket.timeout.ms"; | ||
|
|
||
| /** | ||
| * Protocol used to communicate with brokers. | ||
| * Default value: plaintext | ||
| */ | ||
| static const constexpr char* SECURITY_PROTOCOL = "security.protocol"; | ||
|
|
||
| /** | ||
| * SASL mechanism to use for authentication. | ||
| * Default value: GSSAPI | ||
| */ | ||
| static const constexpr char* SASL_MECHANISM = "sasl.mechanisms"; | ||
|
|
||
| /** | ||
| * SASL username for use with the PLAIN and SASL-SCRAM-.. mechanism. | ||
| */ | ||
| static const constexpr char* SASL_USERNAME = "sasl.username"; | ||
|
|
||
| /** | ||
| * SASL password for use with the PLAIN and SASL-SCRAM-.. mechanism. | ||
| */ | ||
| static const constexpr char* SASL_PASSWORD = "sasl.password"; | ||
|
|
||
| /** | ||
| * Shell command to refresh or acquire the client's Kerberos ticket. | ||
| */ | ||
| static const constexpr char* SASL_KERBEROS_KINIT_CMD = "sasl.kerberos.kinit.cmd"; | ||
|
|
||
| /** | ||
| * The client's Kerberos principal name. | ||
| */ | ||
| static const constexpr char* SASL_KERBEROS_SERVICE_NAME = "sasl.kerberos.service.name"; | ||
|
|
||
| /** | ||
| * Set to "default" or "oidc" to control with login method to be used. | ||
| * If set to "oidc", the following properties must also be specified: | ||
| * sasl.oauthbearer.client.id | ||
| * sasl.oauthbearer.client.secret | ||
| * sasl.oauthbearer.token.endpoint.url | ||
| * Default value: default | ||
| */ | ||
| static const constexpr char* SASL_OAUTHBEARER_METHOD = "sasl.oauthbearer.method"; | ||
|
|
||
| /** | ||
| * Public identifier for the applicaition. | ||
| * Only used with "sasl.oauthbearer.method=oidc". | ||
| */ | ||
| static const constexpr char* SASL_OAUTHBEARER_CLIENT_ID = "sasl.oauthbearer.client.id"; | ||
|
|
||
| /** | ||
| * Client secret only known to the application and the authorization server. | ||
| * Only used with "sasl.oauthbearer.method=oidc". | ||
| */ | ||
| static const constexpr char* SASL_OAUTHBEARER_CLIENT_SECRET = "sasl.oauthbearer.client.secret"; | ||
|
|
||
| /** | ||
| * Allow additional information to be provided to the broker. Comma-separated list of key=value pairs. | ||
| * Only used with "sasl.oauthbearer.method=oidc". | ||
| */ | ||
| static const constexpr char* SASL_OAUTHBEARER_EXTENSIONS = "sasl.oauthbearer.extensions"; | ||
|
|
||
| /** | ||
| * Client use this to specify the scope of the access request to the broker. | ||
| * Only used with "sasl.oauthbearer.method=oidc". | ||
| */ | ||
| static const constexpr char* SASL_OAUTHBEARER_SCOPE = "sasl.oauthbearer.scope"; | ||
|
|
||
| /** | ||
| * OAuth/OIDC issuer token endpoint HTTP(S) URI used to retreve token. | ||
| * Only used with "sasl.oauthbearer.method=oidc". | ||
| */ | ||
| static const constexpr char* SASL_OAUTHBEARER_TOKEN_ENDPOINT_URL = "sasl.oauthbearer.token.endpoint.url"; | ||
|
|
||
| /** | ||
| * SASL/OAUTHBEARER configuration. | ||
| * The format is implementation-dependent and must be parsed accordingly. | ||
| */ | ||
| static const constexpr char* SASL_OAUTHBEARER_CONFIG = "sasl.oauthbearer.config"; | ||
|
|
||
| /** | ||
| * Enable the builtin unsecure JWT OAUTHBEARER token handler if no oauthbearer_refresh_cb has been set. | ||
| * Should only be used for development or testing, and not in production. | ||
| * Default value: false | ||
| */ | ||
| static const constexpr char* ENABLE_SASL_OAUTHBEARER_UNSECURE_JWT = "enable.sasl.oauthbearer.unsecure.jwt"; | ||
| }; | ||
|
|
||
| } } // end of KAFKA_API::clients | ||
|
|
Oops, something went wrong.