Skip to content
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

Support partitionID in Azure eventhub input #36907

Open
Martin-Kemp opened this issue Oct 19, 2023 · 3 comments
Open

Support partitionID in Azure eventhub input #36907

Martin-Kemp opened this issue Oct 19, 2023 · 3 comments
Labels
Stalled Team:Cloud-Monitoring Label for the Cloud Monitoring team

Comments

@Martin-Kemp
Copy link

Describe the enhancement:

Currently partitionID is not supported in Azure eventhub input. It's commented out in the code because Azure SDK apparently doesn't support it. See commented out code here: https://github.com/elastic/beats/blob/main/x-pack/filebeat/input/azureeventhub/input.go#L197
and here: https://github.com/elastic/beats/blob/main/x-pack/filebeat/input/azureeventhub/eph.go#L77

Is this still the case?

As far as I can see partitionID is supported: https://github.com/Azure/azure-event-hubs-go

Describe a specific use case for the enhancement or feature:

PartitionID is very useful for downstream applications consuming eventhub data, we use MQTT topic strings in our partitionID and use this to route data.

@botelastic botelastic bot added the needs_team Indicates that the issue/PR needs a Team:* label label Oct 19, 2023
@elasticmachine
Copy link
Collaborator

Pinging @elastic/security-external-integrations (Team:Security-External Integrations)

@botelastic botelastic bot removed the needs_team Indicates that the issue/PR needs a Team:* label label Oct 24, 2023
@bhapas bhapas self-assigned this Oct 24, 2023
@Martin-Kemp
Copy link
Author

I can confirm that the new SDK works. I tested this basic example: https://github.com/Azure/azure-sdk-for-go/blob/main/sdk/messaging/azeventhubs/example_consuming_events_test.go
and followed this documentation: https://pkg.go.dev/github.com/Azure/azure-sdk-for-go/sdk/messaging/azeventhubs#section-readme

I sent a message to an eventhub and specified the partitionKey then read the message and got the partitionKey:

Received message: Your message content, PartitionKey: %!d(string=your-partition-key), sequence number: 0, enqueued time: 2023-10-27 10:34:41.948 +0000 UTC

By the way, it turns out I was looking for PartitionKey, not PartitionID. But both should be available with the new SDK.

@bhapas bhapas removed their assignment Oct 30, 2023
@botelastic botelastic bot added the needs_team Indicates that the issue/PR needs a Team:* label label Jan 31, 2024
@andrewkroh andrewkroh added the Team:Cloud-Monitoring Label for the Cloud Monitoring team label Jan 31, 2024
@botelastic botelastic bot removed the needs_team Indicates that the issue/PR needs a Team:* label label Jan 31, 2024
@botelastic
Copy link

botelastic bot commented Jan 30, 2025

Hi!
We just realized that we haven't looked into this issue in a while. We're sorry!

We're labeling this issue as Stale to make it hit our filters and make sure we get back to it as soon as possible. In the meantime, it'd be extremely helpful if you could take a look at it as well and confirm its relevance. A simple comment with a nice emoji will be enough :+1.
Thank you for your contribution!

@botelastic botelastic bot added the Stalled label Jan 30, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
Stalled Team:Cloud-Monitoring Label for the Cloud Monitoring team
Projects
None yet
Development

Successfully merging a pull request may close this issue.

5 participants