Reads from NSQ, Publishes to Kafka
Project description
Reads from NSQ, Publishes to Kafka
Installation
pip install nsq2kafka
Examples
Basic example
nsq2kafka --nsq-topic=test --nsq-nsqd-tcp-addresses=localhost:4150
Realistic example
nsq2kafka --nsq-topic=json_clicks \
--nsq-lookupd-http-addresses=lookupd1.example.com:4161,lookupd2.example.com:4161 \
--nsq-max-in-flight=5000 \
--nsq-channel=nsq2Kafka \
--kafka-bootstrap-servers=kafka1.example.com:9092,kafka2.exampkel.com:9092 \
--kafka-topic=click_stream_json \
--kafka-message-key=user_id
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.
| Filename, size | File type | Python version | Upload date | Hashes |
|---|---|---|---|---|
| Filename, size nsq2kafka-0.0.2-py2.7.egg (6.9 kB) | File type Egg | Python version 2.7 | Upload date | Hashes View |
| Filename, size nsq2kafka-0.0.2.tar.gz (3.3 kB) | File type Source | Python version None | Upload date | Hashes View |
