flume
curl http://127.0.0.1:24060/metrics|python -mjson.tool
kafka
查看kafka消费情况
/usr/local/kafka/bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --group hdfs -topic xxxl --zookeeper xxx/Apps/kafka-cloud
主要关注 Offset(当前已消费的条数)、LogSize(总条数)、Lag(未消费的条数)、Owner
查看topic最新消息
/usr/local/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic pswm-red --from-beginning (--zookeeper xxx/Apps/kafka-cloud 0.8.2之前的版本)
列出kafka机器中的所有topic
/usr/local/kafka/bin/kafka-topics.sh --list --zookeeper xx/Apps/kafka-cloud
elasticsearch
curl -XPUT 10.208.30.157:9200/_cluster/settings -d '{
"transient" : {
"cluster.routing.allocation.exclude._ip" : "10.208.20.74"
}
}'
修改副本数
PUT /my_temp_index/_settings
{
"number_of_replicas": 1
}
指定某些索引不在特定的节点上存储(这个可以使用节点标签来设定,但是没办法 搭建的时候没设定,so。。。)
curl -X PUT "10.208.30.157:9200/my_temp_index/_settings?pretty" -H 'Content-Type: application/json' -d'
{
"index.routing.allocation.include._ip": "10.235.21.17,10.235.21.20"
}
'