Public | Automated Build

Last pushed: 3 years ago
Short Description
Short description is empty for this repo.
Full Description


This project creates an Apache Kafka HTTP endpoint for producing and consuming
messages. It is built on the Dropwizard framework that makes Java REST
services operator-friendly and easy to deploy.

Running in Development with Vagrant

A Vagrantfile is included in the project to quickly get up and running with
virtual machines to run ZooKeeper, Kafka, and the HTTP endpoint.

  1. Install Vagrant
  2. Install Virtual Box
  3. git clone
  4. cd dropwizard-kafka-http
  5. vagrant up
  6. curl -d "topic=http&message=hello&key=0" ""
  7. curl ""

Your original message produced from the consumer:

  • Zookeeper will be running on
  • dropwizard-kafka-http is built cleanly before Zookeeper installs in vagrant/
  • Kafka Broker One is running on
  • dropwizard-kafka-http launches on after the Kafka Broker starts in vagrant/

If you want you can log in to the machines using vagrant ssh zookeeper and vagrant ssh brokerOne.

Running in Your Own Environments

For deployment, you'll need to build the project with Maven. Dropwizard projects
produce "fat jars" so that you'll get a standalone binary ready to distribute
and run with your production Java runtime. Assuming that ZooKeeper and Kafka are
already running, edit the included kafka-http.yml to reflect the appropriate
addresses for the HTTP endpoint to connect to these services.

Then, use the standard server Dropwizard command to start up the
HTTP server on port 8080, passing the config file as argument:

$ mvn package
$ java -jar target/dropwizard-kafka-http-0.0.1-SNAPSHOT.jar server kafka-http.yml
$ curl -d "topic=http&message=hello&key=0" http://localhost:8080/message
$ curl "http://localhost:8080/message?topic=http"

You will also find an operator's interface with metrics and other info on port

It is recommended that you run the process under your preferred init or service
supervision tool. See the Dropwizard configuration reference for extensive
customization options for the HTTP server, logging, etc.

dropwizard-kafka-http api methods

Produce messages

POST /message



key=$key1, ... etc

Produces messages on topic.

topic   - required topic name
key     - optional key text. Multiple values are possible
message - required message text. Multiple values are possible

Note: if keys are passed, then passed keys count should match messages count.

400     - wrong parameters passed

Consume messages

GET /message?topic=$topic&timeout=$timeout
Returns consumed messages available on topic.

topic   - required topic name
timeout - optional timeout in ms

400     - wrong parameters passed
Docker Pull Command
Source Repository