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

grep functionality inside consumer.subscribe #1650

Open
mac4manu opened this issue Dec 15, 2023 · 0 comments
Open

grep functionality inside consumer.subscribe #1650

mac4manu opened this issue Dec 15, 2023 · 0 comments

Comments

@mac4manu
Copy link

mac4manu commented Dec 15, 2023

Is your feature request related to a problem? Please describe.

I used below function to subscribe the topic-D, But didn't get intended result. Some values were missing in that response.

await consumer.subscribe({ topics: ['topic-D'], fromBeginning: true })

Then I tried to use kcat command on terminal to same broker with topic and a grep command 'expected string', then It worked

Describe the solution you'd like
It would helpful if we can extend the .subscribe function to accept parameter like grep

Additional context
I am following below page
https://kafka.js.org/docs/consuming

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant