zoukankan      html  css  js  c++  java
  • kafka基本操作

    1. 启动kafka

    ./bin/kafka-server-start.sh config/server.properties 

    2. 创建topic

    ./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

    3. 查询topic

    ./bin/kafka-topics.sh --list --zookeeper localhost:2181

    4. 查询topic的详细描述

    ./bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test
    

    5. 发送数据

    ./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
    

    6. 接收数据

    ./bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
    ## --from-beginning表示从头开始读,如果不加的话,从启动consumer开始接收数据

    7. 删除topic

    ./bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic test
     注意:如果kafaka启动时加载的配置文件中server.properties没有配置delete.topic.enable=true,那么此
    时的删除并不是真正的删除,而是把topic标记为:marked for deletion
    – 此时你若想真正删除它,可以登录zookeeper客户端,进入终端后,删除相应节点
    zkCli.sh 登录进去之后
    ls /brokers/topics  查看topic
    rmr /brokers/topics/test 把对应的topic删除
    

    8. 查询topic的offset的范围

    用下面命令可以查询到topic:test broker:master:9092的offset的最小值:
    ./bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list master:9092 --topic test --time -2
    查询offset的最大值:
    ./bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list master:9092 --topic test --time -1
  • 相关阅读:
    dynamic_cast
    struct 字节对齐详解
    CentOS修改系统的默认启动模式为命令号界面
    linux系统备份还原
    linux 缺少libxxx.a 静态链接库
    linux下SVN忽略文件/文件夹的方法
    取消svn add
    centos 中文乱码解决办法2
    安装rpm包时遇到error: Failed dependencies:错误
    Linux rpm 命令参数使用详解[介绍和应用]
  • 原文地址:https://www.cnblogs.com/654wangzai321/p/9940150.html
Copyright © 2011-2022 走看看