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.
Source Distribution
nsq2kafka-0.0.2.tar.gz
(3.3 kB
view hashes)
Built Distribution
nsq2kafka-0.0.2-py2.7.egg
(6.9 kB
view hashes)