Neologistic Paraphasic Mumbling
    Share your code. npm Orgs help your team discover, share, and reuse code. Create a free org »

    seneca-kafka-transportpublic

    seneca-kafka-transport

    Kafka transport module for seneca. To run the example code:

    download the latest Kafka build from http://kafka.apache.org/downloads.html (tested against 0.8.1)

    unpack and follow the build instructions to create Kafka binaries for your system

    cd to the kafka directory

    cd kafka-0.8.1-src/kafka

    start zookeeper

    nohup bin/zookeeper-server-start.sh config/zookeeper.properties >zk.log 2>&1 &

    start kafka

    nohup bin/kafka-server-start.sh config/server.properties >kafka1.log 2>&1 &

    create a request topic

    bin /kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 3 --topic request

    create a reponse topic

    bin /kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 3 --topic response

    cd into the module test folder

    cd seneca-kafka-transport/test

    initialize the zookeeper configuration

    node setConfig.js

    run the server

    node server.js

    and the client

    node client.js

    Support

    If you're using this module, feel free to contact me on twitter if you have any questions! :) @rjrodger

    Current Version: 0.1.1

    Tested on: node 0.10.24

    install

    npm i seneca-kafka-transport

    Downloadslast 7 days

    1

    version

    0.2.4

    license

    MIT

    repository

    github.com

    last publish

    collaborators

    • avatar
    • avatar