Skip to content

Commit

Permalink
Rename to just kafka-console-consumer
Browse files Browse the repository at this point in the history
  • Loading branch information
eapache committed May 1, 2015
1 parent 74e5489 commit 0143cea
Show file tree
Hide file tree
Showing 5 changed files with 13 additions and 13 deletions.
2 changes: 1 addition & 1 deletion tools/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,6 @@ This folder contains applications that are useful for exploration of your Kafka
Some of these tools mirror tools that ship with Kafka, but these tools won't require installing the JVM to function.

- [kafka-console-producer](./kafka-console-producer): a command line tool to produce a single message to your Kafka custer.
- [kafka-console-topicconsumer](./kafka-console-topicconsumer): a command line tool to consume partitions of a topic on your Kafka cluster.
- [kafka-console-consumer](./kafka-console-consumer): a command line tool to consume partitions of a topic on your Kafka cluster.

To install all tools, run `go get github.com/Shopify/sarama/tools/...`
2 changes: 2 additions & 0 deletions tools/kafka-console-consumer/.gitignore
Original file line number Diff line number Diff line change
@@ -0,0 +1,2 @@
kafka-console-consumer
kafka-console-consumer.test
Original file line number Diff line number Diff line change
@@ -1,29 +1,29 @@
# kafka-console-topicconsumer
# kafka-console-consumer

A simple command line tool to consume partitions of a topic and print the messages
on the standard output.
A simple command line tool to consume partitions of a topic and print the
messages on the standard output.

### Installation

go get github.com/Shopify/sarama/tools/kafka-console-topicconsumer
go get github.com/Shopify/sarama/tools/kafka-console-consumer

### Usage

# Minimum invocation
kafka-console-topicconsumer -topic=test -brokers=kafka1:9092
kafka-console-consumer -topic=test -brokers=kafka1:9092

# It will pick up a KAFKA_PEERS environment variable
export KAFKA_PEERS=kafka1:9092,kafka2:9092,kafka3:9092
kafka-console-topicconsumer -topic=test
kafka-console-consumer -topic=test

# You can specify the offset you want to start at. It can be either
# `oldest`, `newest`. The default is `newest`.
kafka-console-topicconsumer -topic=test -offset=oldest
kafka-console-topicconsumer -topic=test -offset=newest
kafka-console-consumer -topic=test -offset=oldest
kafka-console-consumer -topic=test -offset=newest

# You can specify the partition(s) you want to consume as a comma-separated
# list. The default is `all`.
kafka-console-topicconsumer -topic=test -partitions=1,2,3
kafka-console-consumer -topic=test -partitions=1,2,3

# Display all command line options
kafka-console-topicconsumer -help
kafka-console-consumer -help
2 changes: 0 additions & 2 deletions tools/kafka-console-topicconsumer/.gitignore

This file was deleted.

0 comments on commit 0143cea

Please sign in to comment.