We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
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
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
kcat
Describe the solution you'd like It would helpful if we can extend the .subscribe function to accept parameter like grep
.subscribe
grep
Additional context I am following below page https://kafka.js.org/docs/consuming
The text was updated successfully, but these errors were encountered:
No branches or pull requests
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 workedDescribe the solution you'd like
It would helpful if we can extend the
.subscribe
function to accept parameter likegrep
Additional context
I am following below page
https://kafka.js.org/docs/consuming
The text was updated successfully, but these errors were encountered: