Repository files navigation

Kafka Event Client Tool

• Publish message via Rest API
• Configurable consume message

1. Download the binary file onrelease page
2. Create yaml config file based on example below

Example Config

# config.yamladdress:localhost:8123debug:falsekafka:addresses:    -localhost:9092consumer:enabled:truegroupId:starboosttopics:    -paybill    -tap_snapoutput:stdout:truefile:starboost.log

Run starboost

$ ./starboost --config=config.yaml

Publish message via endpointPOST /publish. You can use cURL or Rest Client.

Example 1

curl --location --request POST'localhost:8123/publish' \--header'Content-Type: application/json' \--data-raw'{    "topic": "paybill",    "message": "some message"}'

Example 2

curl --location --request POST'localhost:8123/publish' \--header'Content-Type: application/json' \--data-raw'{    "topic": "paybill",    "message": {        "foo": "bar"    }}'

You can see the incoming messages on your terminal or log file based on consumer output config.

Example Config

consumer:...output:stdout:truefile:starboost.log

• Filterable on consuming messages
• Dockerize

1. Fork the Project
2. Create your Feature Branch (git checkout -b feature/AmazingFeature)
3. Commit your Changes (git commit -m 'Add some AmazingFeature')
4. Push to the Branch (git push origin feature/AmazingFeature)
5. Open a Pull Request

Distributed under the MIT License. SeeLICENSE for more information.