11/14/2023 0 Comments Event hub![]() ![]() To learn on how to generate the connection string, take a look at this documentation. The connection string for EventHubs already include all the necessary information to connection to your EventHub. Instead of supplying namespace, sharedAccessKey, sharedAccessName … etc, you can just supply the connection string for your eventHub. ![]() By default it set to use. which stores all checkpoint offsets into Azure Blob Storage. Users can, optionally, provide their own implementation of CheckpointStore which will store ownership and checkpoint information. Sets the CheckpointStore the EventProcessorClient will use for storing partition ownership and checkpoint information. Works jointly with checkpointBatchSize.Ĭ-store Sets the batch timeout between each checkpoint updates. Works jointly with checkpointBatchTimeout.Ĭ-batch-timeout Sets the batch size between each checkpoint updates. By default the consumer will use the .ExceptionHandler to deal with exceptions, that will be logged at WARN or ERROR level and ignored.Ĭ-batch-size The option is a .StorageSharedKe圜redential type.Ĭ-error-handlerĪllows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by the routing Error Handler. In case you chose the default BlobCheckpointStore, StorageSharedKe圜redential can be injected to create the azure client, this holds the important authentication information. In case you chose the default BlobCheckpointStore, this sets the blob container that shall be used by the BlobCheckpointStore to store the checkpoint offsets.Ĭ-storage-shared-key-credential In case you chose the default BlobCheckpointStore, this sets Azure account name to be used for authentication with azure blob services.Ĭ-container-name In case you chose the default BlobCheckpointStore, this sets access key for the associated azure account name to be used for authentication with azure blob services.Ĭ-account-name This can be used for automatic configuring JDBC data sources, JMS connection factories, AWS Clients, etc.Ĭ-access-key This is used for automatic autowiring options (the option must be marked as autowired) by looking up in the registry to find if there is a single instance of matching type, which then gets configured on the component. Default value is AmqpTransportType#AMQP.Ĭ-enabled Sets the transport type by which all the communication with Azure Event Hubs occurs. The option is a .AmqpRetryOptions type.Ĭ-transport-type If not specified, the default retry options are used. Sets the retry policy for EventHubAsyncClient.
0 Comments
Leave a Reply. |
AuthorWrite something about yourself. No need to be fancy, just an overview. ArchivesCategories |