Skip to content

Latest commit

 

History

History
60 lines (41 loc) · 1.69 KB

README.md

File metadata and controls

60 lines (41 loc) · 1.69 KB
Raw

Examples

Dependencies

Before using any of the examples, you will need to have a Kafka cluster set up. This repository contains a simple docker-compose file that can spin up or down a full stack that managages a single-node kafka cluster. Run:

For Kafka

cd $GOPATH/src/github.com/veritone/go-messaging-lib/example
docker-compose -f docker-compose.kafka.yaml up -d

Go to:

  • localhost:9001: kafka-manager instance provides Admin tools and statistics for Kafka broker.
  • localhost:8000: kafka-topic-ui instance provides Admin tools and statistics for Kafka topics.
  • localhost:8004: zookeeper-web-ui instance provides Admin tools and statistics for Zookeeper.

For NSQ

cd $GOPATH/src/github.com/veritone/go-messaging-lib/example
docker-compose -f docker-compose.nsq.yaml up -d

Once all components are ready, spin with admin ui for troubleshooting:

  • Install nsqadmin locally with brew install nsq
  • Start nsqadmin with nsqadmin --lookupd-http-address=localhost:4161

kafka-sample

kafka-sample service provides common use cases of Kafka eventing system. Start server by running:

cd $GOPATH/src/github.com/veritone/go-messaging-lib/example/kafka-sample/
govend
go run main.go -p <port>

kafka-stream

kafka-sample service provides an example for using the streaming interface to process a text file. Start server by running:

cd $GOPATH/src/github.com/veritone/go-messaging-lib/example/kafka-stream/
govend
go run main.go

nsq-sample

nsq-sample service provides common use cases of NSQ eventing system. Start server by running:

cd $GOPATH/src/github.com/veritone/go-messaging-lib/example/nsq-sample/
govend
go run main.go -p <port>