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
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.
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 |