bin/kafka-topics.sh --zookeeper localhost:2181 --list
bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic mytopic
bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic mytopic --config retention.ms=1000
... wait a minute ...
function findValues(obj, key){ | |
return findValuesHelper(obj, key, []); | |
} | |
function findValuesHelper(obj, key, list) { | |
if (!obj) return list; | |
if (obj instanceof Array) { | |
for (var i in obj) { | |
list = list.concat(findValuesHelper(obj[i], key, [])); | |
} |
bin/kafka-topics.sh --zookeeper localhost:2181 --list
bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic mytopic
bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic mytopic --config retention.ms=1000
... wait a minute ...