Kafka常用命令

常用命令

# 查看主题详情
bin/kafka-topics.sh --describe --zookeeper  10.1.243.147:2181 --topic my_topic2
# 创建主题
kafka-topics.sh --create --zookeeper 10.1.243.147:2181 --topic my_topic3 -partitions 3 --replication-factor 1

# 修改分区
bin/kafka-topics.sh --alter --zookeeper 10.1.243.147:2181 --topic tripFund --partitions 50
// 发送消息
kafka-console-producer.sh --broker-list  101.37.174.158:9093 --topic my_topic
//消费消息
kafka-console-consumer.sh --bootstrap-server  101.37.174.158:9092,101.37.174.158:9093,101.37.174.158:9094 --from-beginning  --topic 
 my_topic

kafka-configs --zookeeper zookeeper1:2181  --describe --entity-type brokers --entity-default --all | grep socket.request.max.bytes

107896
列出目标权限
ls -Z /data/haproxy/log/haproxy.log
要更改日志文件的SELinux上下文，请使用以下命令：
chcon -t syslogd_var_log_t /data/haproxy/log/haproxy.log