Skip to content
A LoopBack 4 example application for Kafka integration
Branch: master
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
Type Name Latest commit message Commit time
Failed to load latest commit information.
.vscode Initial commits Oct 30, 2018
public
src
test
.gitignore
.npmrc Initial commits Oct 30, 2018
.prettierignore
.prettierrc
.yo-rc.json
DEVELOPING.md Initial commits Oct 30, 2018
LICENSE
README.md Expose server-sent events Oct 30, 2018
docker-compose.yml Create consumers using uuid Nov 1, 2018
index.js Initial commits Oct 30, 2018
index.ts
package.json
tsconfig.json Initial commits Oct 30, 2018
tslint.build.json Initial commits Oct 30, 2018
tslint.json Initial commits Oct 30, 2018

README.md

loopback4-example-kafka

A LoopBack 4 example application for Kafka integration.

See related issues:

Getting started

Start a Kafka instance

docker-compose up

Start the application

npm start

Now you can try out on http://localhost:3000/explorer.

To use curl:

  • Create new topics
curl -X POST "http://127.0.0.1:3000/topics" -H "accept: */*" -H "Content-Type: application/json" -d "[\"demo\"]"
  • Publish messages to demo topic:
curl -X POST "http://127.0.0.1:3000/topics/demo/messages" -H "accept: */*" -H "Content-Type: application/json" -d "[\"test messsage\"]"
  • Receive messages from demo topic:
curl -X GET "http://127.0.0.1:3000/topics/demo/messages?limit=3" -H "accept: */*"

LoopBack

You can’t perform that action at this time.