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

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。