Ottomata has uploaded a new change for review.
https://gerrit.wikimedia.org/r/78924
Change subject: Adding mirror-maker and consumer-offset-checker to kafka bin
script
......................................................................
Adding mirror-maker and consumer-offset-checker to kafka bin script
Change-Id: I6a6ee54ef34c5809a6c55b12bd1aed778ab1cac1
---
M debian/bin/kafka
1 file changed, 15 insertions(+), 2 deletions(-)
git pull ssh://gerrit.wikimedia.org:29418/operations/debs/kafka
refs/changes/24/78924/1
diff --git a/debian/bin/kafka b/debian/bin/kafka
index 68d26f8..1109f2c 100755
--- a/debian/bin/kafka
+++ b/debian/bin/kafka
@@ -25,6 +25,9 @@
$SCRIPT_NAME simple-consumer-shell [opts]
$SCRIPT_NAME replay-log-producer [opts]
+ $SCRIPT_NAME mirror-maker [opts]
+ $SCRIPT_NAME consumer-offset-checker [opts]
+
$SCRIPT_NAME check-reassignment-status [opts]
$SCRIPT_NAME preferred-replica-election [opts]
@@ -139,6 +142,15 @@
kafka_run_class kafka.tools.ReplayLogProducer $@
}
+cmd_mirror_maker() {
+ export JMX_PORT=${JMX_PORT:-9993}
+ kafka_run_class kafka.tools.MirrorMaker $@
+}
+
+cmd_consumer_offset_checker() {
+ kafka_run_class kafka.tools.ConsumerOffsetChecker $@
+}
+
cmd_check_reassignment_status() {
kafka_run_class kafka.admin.CheckReassignmentStatus $@
}
@@ -193,12 +205,12 @@
while test $# != 0
do
case "$1" in
- create-topic | delete-topic | list-topic | console-producer |
console-consumer | simple-consumer-shell | replay-log-producer |
check-reassignment-status | preferred-replica-election | producer-perf-test |
consumer-perf-test | simple-consumer-perf-test | server-start | server-stop |
zookeeper-start | zookeeper-stop | zookeeper-shell )
+ create-topic | delete-topic | list-topic | console-producer |
console-consumer | simple-consumer-shell | replay-log-producer | mirror-maker |
consumer-offset-checker | check-reassignment-status |
preferred-replica-election | producer-perf-test | consumer-perf-test |
simple-consumer-perf-test | server-start | server-stop | zookeeper-start |
zookeeper-stop | zookeeper-shell )
command="$1"; shift; break;
shift;
break;
;;
- -h|--help)
+ -h|--help|help)
usage
exit 0
;;
@@ -213,3 +225,4 @@
function_name=$(echo "${command}" | tr - _)
# call the command function
"cmd_$function_name" "$@"
+
--
To view, visit https://gerrit.wikimedia.org/r/78924
To unsubscribe, visit https://gerrit.wikimedia.org/r/settings
Gerrit-MessageType: newchange
Gerrit-Change-Id: I6a6ee54ef34c5809a6c55b12bd1aed778ab1cac1
Gerrit-PatchSet: 1
Gerrit-Project: operations/debs/kafka
Gerrit-Branch: debian
Gerrit-Owner: Ottomata <[email protected]>
_______________________________________________
MediaWiki-commits mailing list
[email protected]
https://lists.wikimedia.org/mailman/listinfo/mediawiki-commits
