Skip to content

Commit

Permalink
Update Kafka instruction
Browse files Browse the repository at this point in the history
  • Loading branch information
junegunn committed Sep 20, 2017
1 parent ed4e46a commit fec1f68
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -69,6 +69,8 @@ to a remote Kafka cluster in JSON format instead of building the in-memory
database.

```sh
alias hbase-packet-inspector='java -Xmx2g -jar hbase-packet-inspector-0.2.0.jar'

# Both requests and responses are sent to hbase-traffic topic.
# - See boolean "inbound?" field to differentiate two types of records
hbase-packet-inspector --kafka "bootstrap1:9092,bootstrap2:9092/hbase-traffic"
Expand All @@ -83,7 +85,8 @@ hbase-packet-inspector --kafka "bootstrap1:9092,bootstrap2:9092/hbase-requests/"
hbase-packet-inspector --kafka "bootstrap1:9092,bootstrap2:9092//hbase-requests"

# Additional key-value pairs to be included in each record
hbase-packet-inspector --kafka "bootstrap1:9092,bootstrap2:9092/hbase-traffic?service=twitter&cluster=feed"
hbase-packet-inspector \
--kafka "bootstrap1:9092,bootstrap2:9092/hbase-traffic?service=twitter&cluster=feed"
```

Shipping the information to Kafka has the following benefits:
Expand Down

0 comments on commit fec1f68

Please sign in to comment.