-
Notifications
You must be signed in to change notification settings - Fork 4.9k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Upgrade azure-eventhub to the new Event Hub SDK #39796
Commits on Aug 2, 2024
-
Configuration menu - View commit details
-
Copy full SHA for cd799af - Browse repository at this point
Copy the full SHA cd799afView commit details -
Configuration menu - View commit details
-
Copy full SHA for 983fd79 - Browse repository at this point
Copy the full SHA 983fd79View commit details -
Configuration menu - View commit details
-
Copy full SHA for b7af8a5 - Browse repository at this point
Copy the full SHA b7af8a5View commit details -
Configuration menu - View commit details
-
Copy full SHA for 926eb80 - Browse repository at this point
Copy the full SHA 926eb80View commit details -
Configuration menu - View commit details
-
Copy full SHA for 4a8ddaf - Browse repository at this point
Copy the full SHA 4a8ddafView commit details -
Configuration menu - View commit details
-
Copy full SHA for 87525a8 - Browse repository at this point
Copy the full SHA 87525a8View commit details -
Configuration menu - View commit details
-
Copy full SHA for b79abea - Browse repository at this point
Copy the full SHA b79abeaView commit details -
Configuration menu - View commit details
-
Copy full SHA for 3f43d21 - Browse repository at this point
Copy the full SHA 3f43d21View commit details -
Update x-pack/filebeat/input/azureeventhub/v1_input_test.go
Co-authored-by: Tiago Queiroz <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for bd410eb - Browse repository at this point
Copy the full SHA bd410ebView commit details -
Configuration menu - View commit details
-
Copy full SHA for edd984e - Browse repository at this point
Copy the full SHA edd984eView commit details -
Configuration menu - View commit details
-
Copy full SHA for 023cc36 - Browse repository at this point
Copy the full SHA 023cc36View commit details -
Configuration menu - View commit details
-
Copy full SHA for 78b7a10 - Browse repository at this point
Copy the full SHA 78b7a10View commit details -
Configuration menu - View commit details
-
Copy full SHA for 73f35c0 - Browse repository at this point
Copy the full SHA 73f35c0View commit details -
Retry starting the processor 30s after an error
I don't wanna use `time.Sleep`, this is just a test.
Configuration menu - View commit details
-
Copy full SHA for 00befb0 - Browse repository at this point
Copy the full SHA 00befb0View commit details -
Configuration menu - View commit details
-
Copy full SHA for 41e104c - Browse repository at this point
Copy the full SHA 41e104cView commit details -
Configuration menu - View commit details
-
Copy full SHA for 1b617ba - Browse repository at this point
Copy the full SHA 1b617baView commit details -
Adding acker.LastEventPrivateReporter()
Trying to listen for the ack of the last event, and store its checkpoint information
Configuration menu - View commit details
-
Copy full SHA for 2a9e51c - Browse repository at this point
Copy the full SHA 2a9e51cView commit details -
Configuration menu - View commit details
-
Copy full SHA for 947ec02 - Browse repository at this point
Copy the full SHA 947ec02View commit details -
Configuration menu - View commit details
-
Copy full SHA for 1431e97 - Browse repository at this point
Copy the full SHA 1431e97View commit details -
Configuration menu - View commit details
-
Copy full SHA for 2922b5f - Browse repository at this point
Copy the full SHA 2922b5fView commit details -
Configuration menu - View commit details
-
Copy full SHA for ea4b6ba - Browse repository at this point
Copy the full SHA ea4b6baView commit details -
Configuration menu - View commit details
-
Copy full SHA for eedded6 - Browse repository at this point
Copy the full SHA eedded6View commit details -
Configuration menu - View commit details
-
Copy full SHA for a871280 - Browse repository at this point
Copy the full SHA a871280View commit details -
Add support for partition key in eventhub metadata
Alongside the partition ID, users can optional send event with a partition key. Add an (optional) partition key to the event hub metadata.
Configuration menu - View commit details
-
Copy full SHA for fedfcf4 - Browse repository at this point
Copy the full SHA fedfcf4View commit details -
Add migrate_checkpoint config option
The new migrate_checkpoint config option controls if the input v2 should perform a migration check on start. If migrate_checkpoint is true, the input checks and performs the migration (if v1 info exists) on the very first v2 run. If migrate_checkpoint is false, the input will skip the migration assistant and will not perform any checks or migration.
Configuration menu - View commit details
-
Copy full SHA for c687656 - Browse repository at this point
Copy the full SHA c687656View commit details -
Make starting position adjustable (+validation)
Expand processor options by adding a new `start_position` configuration. Possible values for `start_position` are: - "earliest" to start from the beginning of the event hub retention period. - "latest" to start from new events. The input uses the 'start_position' option when checkpoint information from the storage account container is unavailable (on the input's first start).
Configuration menu - View commit details
-
Copy full SHA for f58aaaa - Browse repository at this point
Copy the full SHA f58aaaaView commit details -
Configuration menu - View commit details
-
Copy full SHA for d539017 - Browse repository at this point
Copy the full SHA d539017View commit details -
Configuration menu - View commit details
-
Copy full SHA for d0a37b0 - Browse repository at this point
Copy the full SHA d0a37b0View commit details -
Configuration menu - View commit details
-
Copy full SHA for 0b7fd84 - Browse repository at this point
Copy the full SHA 0b7fd84View commit details -
Add receive_timeout and receive_count to config
Makes the receive configuration settings available for customization on the input settings. The current default values (receive_timeout: 5s, receive_count: 100) are probably fine, but it is better to make these options available to users.
Configuration menu - View commit details
-
Copy full SHA for 2c6044f - Browse repository at this point
Copy the full SHA 2c6044fView commit details -
Configuration menu - View commit details
-
Copy full SHA for e2f0a43 - Browse repository at this point
Copy the full SHA e2f0a43View commit details -
Configuration menu - View commit details
-
Copy full SHA for 769d199 - Browse repository at this point
Copy the full SHA 769d199View commit details -
Configuration menu - View commit details
-
Copy full SHA for 2eaa9ac - Browse repository at this point
Copy the full SHA 2eaa9acView commit details -
Apply suggestions from code review
Co-authored-by: Andrew Gizas <[email protected]> Co-authored-by: subham sarkar <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for cb62264 - Browse repository at this point
Copy the full SHA cb62264View commit details -
Configuration menu - View commit details
-
Copy full SHA for 91c0229 - Browse repository at this point
Copy the full SHA 91c0229View commit details -
Add config validation on new options
Also update the option description as well adding the default value.
Configuration menu - View commit details
-
Copy full SHA for 0f33396 - Browse repository at this point
Copy the full SHA 0f33396View commit details -
Double-check private data in acknowledged events
It's better to check the private data in the event has the expected type.
Configuration menu - View commit details
-
Copy full SHA for feb52b7 - Browse repository at this point
Copy the full SHA feb52b7View commit details -
Add sequence number and offset to checkpoint log
Adding more details to the message logged on successful store: - sequence_number - offset - enqueued_time
Configuration menu - View commit details
-
Copy full SHA for 9361b56 - Browse repository at this point
Copy the full SHA 9361b56View commit details -
Add teardown() function on the v2 input
The teardown() function is responsible to release all the resources allocated in the setup() function.
Configuration menu - View commit details
-
Copy full SHA for 53925c0 - Browse repository at this point
Copy the full SHA 53925c0View commit details -
Configuration menu - View commit details
-
Copy full SHA for 03f0625 - Browse repository at this point
Copy the full SHA 03f0625View commit details
Commits on Aug 7, 2024
-
Configuration menu - View commit details
-
Copy full SHA for fa5f346 - Browse repository at this point
Copy the full SHA fa5f346View commit details