Push/Pull on Kafka over HTTP
Project description
Flasfka
Push/Pull on Kafka over HTTP
Configuration
To configure how the server should talk to Kafka, the following variables are available. Put this in a file (for example /etc/flasfka.conf.py):
HOSTS=["localhost:9092"] DEFAULT_GROUP="flasfka" CONSUMER_TIMEOUT=0.1 CONSUMER_LIMIT=100
The file will be read at flasfka startup, provided you export its path:
export FLASFKA_CONFIG=/etc/flasfka.conf.py
Usage
Assuming flasfka is configured and running:
send
curl -X POST --data-binary '{"messages": ["msg1", "msg2"]}' "http://127.0.0.1:5000/my-topic/"
This pushes msg1 then msg2 to the topic my-topic.
curl -X POST --data-binary '{"messages": ["msg3"]}' "http://127.0.0.1:5000/my-topic/my-key/"
This pushes msg3 to the topic my-topic with the key my-key.
fetch
curl http://127.0.0.1:5000/my-topic/
This retrieves a maximum of 100 of the last messages posted to my-topic, from the default group flasfka.
curl http://127.0.0.1:5000/my-topic/my-group/
This retrieves a maximum of 100 of the last messages posted to my-topic, from the group my-group.
curl http://127.0.0.1:5000/my-topic/?limit=20
This retrieves a maximum of 20 of the last messages posted to my-topic, from the default group flasfka.
Limitations
Flafska only accepts json data, so your messages need to be in utf-8. If you want to pass arbitrary data, it is recommended to encode them to a suitable format before (e.g. base64).
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.