您的位置:首页 > 新闻 > 资讯 > 深圳华强北封闭了吗_域名申请邮箱_免费网站推广软件哪个好_郑州企业网站优化排名

深圳华强北封闭了吗_域名申请邮箱_免费网站推广软件哪个好_郑州企业网站优化排名

2024/12/25 10:20:12 来源:https://blog.csdn.net/m0_74282926/article/details/144382261  浏览:    关键词:深圳华强北封闭了吗_域名申请邮箱_免费网站推广软件哪个好_郑州企业网站优化排名
深圳华强北封闭了吗_域名申请邮箱_免费网站推广软件哪个好_郑州企业网站优化排名

以下是 Kafka 常用命令的详细汇总,包含了常见的操作命令以及使用案例,表格形式方便查看

命令功能命令格式使用案例
查看 Kafka 版本查看 Kafka 的版本信息bin/kafka-topics.sh --version获取 Kafka 版本信息:
bin/kafka-topics.sh --version
创建 Kafka 主题创建一个新的 Kafka 主题bin/kafka-topics.sh --create --topic <topic_name> --partitions <num_partitions> --replication-factor <replication_factor> --bootstrap-server <broker>创建主题 my_topic,分区数为 3,副本数为 2:
bin/kafka-topics.sh --create --topic my_topic --partitions 3 --replication-factor 2 --bootstrap-server 127.0.0.1:9092
列出 Kafka 主题列出当前 Kafka 集群的所有主题bin/kafka-topics.sh --list --bootstrap-server <broker>列出 Kafka 中所有主题:
bin/kafka-topics.sh --list --bootstrap-server 127.0.0.1:9092
删除 Kafka 主题删除一个现有的 Kafka 主题bin/kafka-topics.sh --delete --topic <topic_name> --bootstrap-server <broker>删除主题 my_topic
bin/kafka-topics.sh --delete --topic my_topic --bootstrap-server 127.0.0.1:9092
查看主题详情查看某个 Kafka 主题的详细信息bin/kafka-topics.sh --describe --topic <topic_name> --bootstrap-server <broker>查看主题 my_topic 的详情:
bin/kafka-topics.sh --describe --topic my_topic --bootstrap-server 127.0.0.1:9092
启动 Kafka 服务启动 Kafka 服务bin/kafka-server-start.sh config/server.properties启动 Kafka 服务:
bin/kafka-server-start.sh config/server.properties
停止 Kafka 服务停止 Kafka 服务bin/kafka-server-stop.sh停止 Kafka 服务:
bin/kafka-server-stop.sh
发送消息到 Kafka 主题向 Kafka 主题发送消息bin/kafka-console-producer.sh --topic <topic_name> --bootstrap-server <broker>my_topic 发送消息:
bin/kafka-console-producer.sh --topic my_topic --bootstrap-server 127.0.0.1:9092
查看 Kafka 主题的消息查看 Kafka 主题的消息bin/kafka-console-consumer.sh --topic <topic_name> --from-beginning --bootstrap-server <broker>查看 my_topic 的消息:
bin/kafka-console-consumer.sh --topic my_topic --from-beginning --bootstrap-server 127.0.0.1:9092
查看 Kafka 消费者组信息查看消费者组的偏移量和状态bin/kafka-consumer-groups.sh --describe --group <group_name> --bootstrap-server <broker>查看消费者组 my_group 的信息:
bin/kafka-consumer-groups.sh --describe --group my_group --bootstrap-server 127.0.0.1:9092

以下是详细命令解析与使用案例

  1. 查看 Kafka 版本
    查看 Kafka 集群的版本信息,帮助确认安装的 Kafka 版本。
bin/kafka-topics.sh --version
  1. 创建 Kafka 主题
    创建一个新的 Kafka 主题,必须指定主题名称、分区数、和副本数。
bin/kafka-topics.sh --create --topic my_topic --partitions 3 --replication-factor 2 --bootstrap-server 127.0.0.1:9092
  1. 列出 Kafka 主题
    查看当前 Kafka 集群中的所有主题,帮助了解集群的结构。
bin/kafka-topics.sh --list --bootstrap-server 127.0.0.1:9092
  1. 删除 Kafka 主题
    删除一个不再需要的 Kafka 主题,释放资源。
bin/kafka-topics.sh --delete --topic my_topic --bootstrap-server 127.0.0.1:9092
  1. 查看主题详情
    查看 Kafka 中某个主题的详细信息,包括分区数、副本分配情况等。
bin/kafka-topics.sh --describe --topic my_topic --bootstrap-server 127.0.0.1:9092
  1. 启动 Kafka 服务
    启动 Kafka 服务,使用指定的配置文件启动 Kafka 服务器。
bin/kafka-server-start.sh config/server.properties
  1. 停止 Kafka 服务
    停止 Kafka 服务,可以在集群维护时使用此命令。
bin/kafka-server-stop.sh
  1. 发送消息到 Kafka 主题
    使用生产者命令行工具发送消息到 Kafka 主题,模拟消息推送。
bin/kafka-console-producer.sh --topic my_topic --bootstrap-server 127.0.0.1:9092
  1. 查看 Kafka 主题的消息
    使用消费者命令行工具从 Kafka 主题中消费消息。
bin/kafka-console-consumer.sh --topic my_topic --from-beginning --bootstrap-server 127.0.0.1:9092
  1. 查看 Kafka 消费者组信息
    查看某个消费者组的偏移量和消费状态,常用于消费进度监控。
bin/kafka-consumer-groups.sh --describe --group my_group --bootstrap-server 127.0.0.1:9092

版权声明:

本网仅为发布的内容提供存储空间,不对发表、转载的内容提供任何形式的保证。凡本网注明“来源:XXX网络”的作品,均转载自其它媒体,著作权归作者所有,商业转载请联系作者获得授权,非商业转载请注明出处。

我们尊重并感谢每一位作者,均已注明文章来源和作者。如因作品内容、版权或其它问题,请及时与我们联系,联系邮箱:809451989@qq.com,投稿邮箱:809451989@qq.com