DR9885 opened a new issue, #15268:
URL: https://github.com/apache/pulsar/issues/15268
**Is your enhancement request related to a problem? Please describe.**
When using the reader, it should be able to filter on a list of keys
**Describe the solution you'd like**
C# example: of reading events for Key 123
```
await _client.NewReader()
.Topic($"persistent://public/default/{bucket}")
.StartMessageId(MessageId.Earliest)
.Keys(new[] {"123"})
.CreateAsync();
```
**Describe alternatives you've considered**
Possible TEMP options
- Using a Sink Connector, and reading from that database (but eventual
consistency issue)
- Using Trino, but that doesn't seem like the right way to go.
- Manually consume events and write to data store to query from.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
