This module is based on kafka-node and node-zookeeper-client. kafka-topics topic-name -deleteĬreate topic kafka-topics -create topic-name p r Įxample: kafka-topics -create some-important-topic p128 r3 retention.ms=31536000000 kafka-topics topic-name -clearįor this to work server config option must be true. This overrides retention.ms=1 and cleanup.policy=delete, waits until the topic is sweeped and restores original configuration overrides for a topic. Set topic configuration override kafka-topics topic-name -c tes=1000000000 retention.ms=86400000ĭelete topic configuration override kafka-topics topic-name -c tes= retention.ms= The enhanced notification payload is being send. Kafka-topics checks brokers version stored in the zookeeper and if brokers version is >= 2 The configuration overrides notification payload changed since kafka 0.9.0. NOTE: The configuration overrides are supported by kafka 0.8.1 and later.
Show all possible configuration overrides (hardcoded) kafka-topics -c
Set topic group offsets (zookeeper based) kafka-topics topic-name group-name offset ]] List topic partition offsets and current group offsets (zookeeper based) kafka-topics topic-name group-name List topic partition offsets and group ids (zookeeper based) kafka-topics topic-name # or a JSON object with tls broker sockets optionsĮxport KAFKA_TOOLS_SSL='' Usage export KAFKA_TOOLS_ZOOKEEPER="/path-to-kafka"įor ssl connections: export KAFKA_TOOLS_SSL=true
0 kommentar(er)
