GitPlanet

Cheap and reliable Node.js hosting starts at $3/month, and $1/month static HTML hosting

Created with love in Canada, visit hostnodejs.com today

Feel like to post an Ad? Learn Details
All Projects → shafreeck → kafka-cli

shafreeck / kafka-cli

Licence: Apache-2.0 license
A command line client of kafka

Programming Languages

go
31211 projects - #10 most used programming language

Labels

clientkafkaclient-side

Projects that are alternatives of or similar to kafka-cli

Riot
Simple and elegant component-based UI library
Stars: ✭ 14,596 (+97206.67%)
Mutual labels:  client-side
PENDOWN
Text-to-HTML conversion tool for web writers, with integrated styling and tag customization.
Stars: ✭ 33 (+120%)
Mutual labels:  client-side
Reddit-Embed
Embed any reddit post onto your website!
Stars: ✭ 15 (+0%)
Mutual labels:  client-side
Final Form
🏁 Framework agnostic, high performance, subscription-based form state management
Stars: ✭ 2,787 (+18480%)
Mutual labels:  client-side
Sree
S3 client for human beings
Stars: ✭ 55 (+266.67%)
Mutual labels:  client-side
Hangons
Web app to parse and save your Hangouts.json file into a more friendly format.
Stars: ✭ 45 (+200%)
Mutual labels:  client-side
Vue.py
Pythonic Vue.js
Stars: ✭ 223 (+1386.67%)
Mutual labels:  client-side
Okuma-Reader
Online book/manga/image set/webtoon reader and library with some key features like Japanese page order, double-page view, touch gestures, multiple languages, and pre-caching of next pages.
Stars: ✭ 31 (+106.67%)
Mutual labels:  client-side
LibManUal
No description or website provided.
Stars: ✭ 18 (+20%)
Mutual labels:  client-side
Discord-Console-hacks
A collection of JavaScript Codes I've made to enhance the User Experience of Discord and some other Discord related stuff
Stars: ✭ 353 (+2253.33%)
Mutual labels:  client-side
AxleJS
Fetch, supercharged.
Stars: ✭ 28 (+86.67%)
Mutual labels:  client-side
Swadeshi
Implementing a Web Based solution through which farmers can participate in a commodity exchange market
Stars: ✭ 21 (+40%)
Mutual labels:  client-side
json-as-xlsx
Create excel from json npm package
Stars: ✭ 103 (+586.67%)
Mutual labels:  client-side
Getsy
A simple browser/client-side web scraper.
Stars: ✭ 238 (+1486.67%)
Mutual labels:  client-side
typechecker
Utilities to get and check variable types (isString, isPlainObject, isRegExp, etc)
Stars: ✭ 44 (+193.33%)
Mutual labels:  client-side
Perfcascade
Responsive, SVG based HAR waterfall viewer
Stars: ✭ 225 (+1400%)
Mutual labels:  client-side
jquery-smarty
jQuery Smarty Plugin (jQSmarty) is a port of the Smarty Templating Engine to Javascript/jQuery, offering a familiar client-side templating solution
Stars: ✭ 18 (+20%)
Mutual labels:  client-side
agollo
🚀Go client for ctrip/apollo (https://github.com/apolloconfig/apollo)
Stars: ✭ 563 (+3653.33%)
Mutual labels:  client-side
MinifyAllCli
📦 A lightweight, simple and easy npm tool to 𝗺𝗶𝗻𝗶𝗳𝘆 JSON/C, HTML and CSS! Also known as MinifyAll core! ⭐ Usable as 𝑪𝑳𝑰 tool or 𝒊𝒎𝒑𝒐𝒓𝒕𝒂𝒃𝒍𝒆 in TS/JS as a 𝑴𝑶𝑫𝑼𝑳𝑬 🥰
Stars: ✭ 21 (+40%)
Mutual labels:  client-side
hack-cs-tools
client side (C-S) penetration toolkit
Stars: ✭ 111 (+640%)
Mutual labels:  client-side
View All Similar Projects ➔

kafka-cli

Install

go get github.com/shafreeck/kafka-cli

Usage

kafka-cli is a console util tool to access kafka cluster

Usage:
  kafka-cli [command]

Available Commands:
  consume     consume topic from kafka
  monitor     display kafka cluster metrics, TODO
  produce     TODO
  topics      list all topics

Flags:
      --brokers string                    broker list, delimited by comma (default "127.0.0.1:9092")
      --buffersize int                    internal channel buffer size (default 256)
      --clientid string                   a user-provided string sent with every request to the brokers for logging debugging, and auditing purposes (default "kafka-cli")
      --config string                     config file (default is $HOME/.kafka-cli.yaml)
      --metadata.refresh duration         metadata refresh frequency (default 10m0s)
      --metadata.retry.backoff duration   backoff between retrying (default 250ms)
      --metadata.retry.max int            total number to request metadata when the cluster has a leader election (default 3)
      --net.dialtimeout duration          timeout of dialing to brokers (default 30s)
      --net.keepalive duration            keepalive period, 0 means disabled
      --net.maxopenrequests int           how many outstanding requests a connection is allowed to have before sending on it blocks (default 5)
      --net.readtimeout duration          timeout of reading messages (default 30s)
      --net.writetimeout duration         timeout of writing messages (default 30s)
  -v, --verbose                           print log messages
      --zookeepers string                 zookeeper server list, delimited by comma, only use when operate topic (default "127.0.0.1:9093")

Use "kafka-cli [command] --help" for more information about a command.

List all topics

./kafka-cli --brokers 127.0.0.1:9092 topics
topic           partition[replicaid...]:offset ...
--------------------------------------------------
unexpected-logs 0[0]:12285581
output-pod2     0[0]:9725580
default-topic   0[0]:13971093
test            0[0]:5
filebeats       0[0]:12488893   1[0]:11301355   2[0]:11301353   3[0]:11301197   4[0]:11301197   5[0]:11301197   6[0]:11301200   7[0]:11301356

Create topics

./kafka-cli --brokers 127.0.0.1:9092 --zookeepers 127.0.0.1:2181 topics create  t1 t2 t3 --partitions 10 --replicas 3

Delete topics

./kafka-cli --brokers 127.0.0.1:9092 --zookeepers 127.0.0.1:2181 topics delete  t1 t2 t3

Consume topics

./kafka-cli --brokers 127.0.0.1:9092 consume default-topic unexpected-logs

Produce messages

TODO

Note that the project description data, including the texts, logos, images, and/or trademarks, for each open source project belongs to its rightful owner. If you wish to add or remove any projects, please contact us at [email protected].