Stored Procedures
Stored procedures are function-like interfaces that extend the functionality of the adapter beyond simple SELECT/INSERT operations with Apache Kafka.
Stored procedures accept a list of parameters, perform their intended function, and then return any relevant response data from Apache Kafka, along with an indication of whether the procedure succeeded or failed.
Apache Kafka Adapter Stored Procedures
| Name | Description |
| CommitOffset | Commits the messages to the connection ConsumerGroupId. |
| CreateSchema | Creates a schema definition of a table in Kafka. |
| GetAdminConsentURL | Gets the admin consent URL that must be opened separately by an admin of a given domain to grant access to your application. Only needed when using custom OAuth credentials. |
| GetOAuthAccessToken | Gets an OAuth authentication token. |
| GetOAuthAuthorizationURL | Gets the authorization URL that must be opened separately by the user to grant access to your application. You will request the OAuthAccessToken from this URL. |
| ProduceMessage | Sends a raw message to Kafka. |
| RefreshOAuthAccessToken | Exchanges a access token for a new access token. |