-
Notifications
You must be signed in to change notification settings - Fork 0
Kafka
/opt/kafka/bin/kafka-topics.sh --list --zookeeper localhost:2181 | sort
/opt/kafka/bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:6667 --topic saas.raw.webnode
watch -d -n 1 'echo saas.raw.{dns,webnode,rsyslogstats,sinkhole} | xargs -n 1 /opt/kafka/bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:6667 --topic | sort'
date ; /opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:6667 --topic saas.raw.webnode --partition 2 | egrep -m 2 c21 ; date
/opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:6667 --topic saas.raw.webnode --partition 0
/opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:6667 --topic saas.raw.webnode --partition 1 --offset 502265 --max-messages 1