Kafka Event Client Tool

• Publish message via Rest API
• Configurable consume message

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

Example Config

# config.yaml address: localhost:8123 debug: false kafka: addresses: - localhost:9092 consumer: enabled: true groupId: starboost topics: - paybill - tap_snap output: stdout: true file: starboost.log

Run starboost

$ ./starboost --config=config.yaml

Publish message via endpoint POST /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: true file: 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. See LICENSE for more information.