Skip to content

Instantly share code, notes, and snippets.

@creese
creese / Kafka Scripts
Last active September 20, 2016 22:24
ZOOKEEPER_CONNECT=zookeeper.service.consul:2181
LEDGER_TOPICS=(ledger-request-pre-release-2 ledger-result-pre-release-2 ledger-account-configuration-pre-release-1 ledger-account-pre-release-2 account-balance-updated-pre-release-3 ledger-entry-added-pre-release-2 __samza_checkpoint_ver_1_for_ledger-balance-tracker_1 __samza_checkpoint_ver_1_for_ledger-eventlog-builder_1 __samza_coordinator_ledger-balance-tracker_1 __samza_coordinator_ledger-eventlog-builder_1 ledger-account-configuration-changelog ledger-request-changelog ledger-result-changelog)
list-topics () {
kafka-topics \
--zookeeper $ZOOKEEPER_CONNECT \
--list
}
describe_topic () {

Keybase proof

I hereby claim:

  • I am creese on github.
  • I am creese (https://keybase.io/creese) on keybase.
  • I have a public key ASDNDLTSWpyS1moGl_s6E35_0Cy_GYklmdAyTEEb_wbPMQo

To claim this, I am signing this object: