loopbackio / loopbackio/loopback4-example-kafka
some observations / enhancement request
Nobody has claimed this yet.
- Dominant language
- TypeScript
- Stars
- 11
- Forks
- 4
- PR merge metrics
- No merged PRs in 30d
Description
@raymondfeng
Thanks for sharing this example.
I tried using your example code and have a few observations that I would like to share with you.
1. I think we should make "offset" a user input.
2. For the case when input "limit" is greater than the number of messages within the selected topic, the explorer is stuck in "Loading" state. I can see that it gets the messages from the backend, but since the messages are less than the requested limit, it just sits there for a timeout to occur and eventually error's out.
Please let me know your thoughts.
Based on your feedback, I am looking forward to add a few things to this example and will be happy to share an updated version with the community.
BTW I am using the latest versions of the following packages.
"@loopback/authentication": "^5.0.0",
"@loopback/authentication-jwt": "^0.5.0",
"@loopback/authorization": "^0.6.4",
"@loopback/boot": "^2.4.1",
"@loopback/core": "^2.9.3",
"@loopback/extension-health": "^0.4.11",
"@loopback/extension-metrics": "^0.3.11",
"@loopback/repository": "^2.11.0",
"@loopback/rest": "^6.0.0",
"@loopback/rest-crud": "^0.8.11",
"@loopback/rest-explorer": "^2.2.8",
"@loopback/service-proxy": "^2.3.6",
"kafka-node": "^5.0.0",
Contributor guide
No contributing guide indexed for this repository
First steps
- Read the whole issue, then the project's contributing guide.
- Comment on the issue to say you are picking it up — it saves two people doing the same work.
- Fork the repository and make your change on a branch.
- Open a pull request that references the issue number.
Research direction
Start with the example code and trace how offset and limit are passed through the explorer to the backend for a selected topic. Verify the behavior when fewer messages are returned than the requested limit, and confirm that offset is exposed as user input and loading completes without waiting for a timeout.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- kafka, typescript
- Domain
- backend, distributed-systems
- Issue type
- Bug
- Difficulty
- 4/5
- Estimated time
- 3-5 days
- Activity status
- Stale
- Clarity
- Needs clarification
- Newbie friendliness
- 30/100