azure.read_event_hub
Read from Azure Event Hub
Properties
| Name | Type | Description | Required |
|---|---|---|---|
| batch_size | integer | Maximum number of records yielded per downstream batch. Default: 1000Minimum: 1 | no |
| flush_ms | integer, null | If set, flush a partial batch after this many ms of inactivity. null or omitted = wait until batch_size or end-of-stream. Default: 1000Minimum: 1 | no |
| event_hub_connection_string | string | The connection string for the Azure Event Hub namespace. | yes |
| event_hub_consumer_group_name | string | The name of the consumer group to read events from. | yes |
| event_hub_name | string | The name of the Azure Event Hub. | yes |
| checkpoint_store_connection_string | string | The connection string for the Azure Storage account used as the checkpoint store. | yes |
| checkpoint_store_container_name | string | The name of the container within the checkpoint store to store the checkpoints. | yes |
| max_batch_size | integer | Maximum number of events to receive in each SDK callback. Renamed from the previous batch_size which used to mean this. Defaults to 300. Default: 300Minimum: 1 | no |
Example
batch_size: 1000
flush_ms: 1000
max_batch_size: 300