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 wildcard pattern in kafka source #3677

Open
msardara opened this issue Nov 16, 2023 · 1 comment
Open

Support wildcard pattern in kafka source #3677

msardara opened this issue Nov 16, 2023 · 1 comment
Labels
enhancement New feature or request plugin - source A plugin to receive data from a service or location.

Comments

@msardara
Copy link

msardara commented Nov 16, 2023

Is your feature request related to a problem? Please describe.
I am trying to create a data prepper pipeline that consumes data from kafka and ingest it into opensearch.
I need to consume from a set of topics whose name is generated dynamically over time, so I don't know it in
advance. I only know that the pattern is always "my-topic-*".

Describe the solution you'd like
I saw that KafkaConsumer supports the subscription to a wildcard topic using patterns,
but it seems data prepper only uses a list of fixed topics.

Is it possible to add the possibility to also consume wildcard topics?

Describe alternatives you've considered (Optional)
I saw that logstash supports this with the topics_pattern key.

@dlvenable dlvenable added enhancement New feature or request plugin - source A plugin to receive data from a service or location. and removed untriaged labels Nov 16, 2023
@msardara
Copy link
Author

msardara commented Jan 31, 2024

Hey guys,

do you have any idea of when this feature will be available?

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
enhancement New feature or request plugin - source A plugin to receive data from a service or location.
Projects
Development

No branches or pull requests

2 participants