首页 > 其他分享 >Kafka常用命令

Kafka常用命令

时间:2023-01-03 11:26:27浏览次数:45  
标签:-- kafka topic sh 常用命令 test Kafka config

1.查看topic列表

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

2.创建一个名为test的topic

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

--replication-factor 表示 kafka保存消息的副本数
--partitions 该参数指定了新创建的主题需要包含多少个分区

3.创建一个消费者并且关注名称为test的topic

./kafka-console-consumer.sh --bootstrap-server IP:9092 --topic test --from-beginning
./kafka-console-consumer.sh --bootstrap-server IP:9092 --topic test --from-beginning --consumer.config ../config/client-sasl.properties

--consumer.config 指定消费者使用的配置文件

4.创建一个生产者并关注名称为test的topic

./kafka-console-producer.sh --broker-list IP:9092 --topic test
./kafka-console-producer.sh --broker-list IP:9092 --topic test --producer.config ../config/client-sasl.properties

--producer.config 指定生产者使用的配置文件

5.查看某个topic下的内容

./kafka-run-class.sh kafka.tools.DumpLogSegments --files XXX.log --print-data-log
XXX.log为要查看的topic物理存储的绝对路径加文件名

标签:--,kafka,topic,sh,常用命令,test,Kafka,config
From: https://www.cnblogs.com/wsmbszyn/p/17021478.html

相关文章

  • kafka常用命令(zookeeper与bootstrap-server)
       在0.9.0.0之后的Kafka,出现了几个新变动,一个是在Server端增加了GroupCoordinator这个角色,另一个较大的变动是将topic的offset信息由之前存储在zookeeper......
  • Kubernetes(k8s) kubectl annotate常用命令
    kubectl在$HOME/.kube目录中查找一个名为config的配置文件。可以通过设置KUBECONFIG环境变量或设置--kubeconfig参数来指定其它kubeconfig文件。本文主要介绍K......
  • [Kafka基础]-- kafka指南
    参考:​​https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol​​​​http://kafka.apache.org/protocol.html​​ ​​介绍​​​​概观​......
  • Linux常用命令
    Linux常用命令 1.cd切换目录菜单~切换到家目录cd/切换到根目录cd-切换到上一次操作的目录cd..或cd../切换到上级目录cd.或cd./切换......
  • Kafka学习笔记(二):Topics, Partitions and Offsets
    KafkaTopicsTopics:一种特殊的数据流就像数据库中的表,但没有所有的约束可以有任意多的Topics一个Topic由它的name定义任意格式的消息格式Topic中的消息序列......
  • Ubuntu 常用命令
    Usingubuntuwhichrails\\查找路径;pwd\\当前目录;sudosu\\切换到管理员;sudomount-tvboxsfsarah/mnt/s......
  • Kubernetes(k8s) kubectl convert常用命令
    kubectl在$HOME/.kube目录中查找一个名为config的配置文件。可以通过设置KUBECONFIG环境变量或设置--kubeconfig参数来指定其它kubeconfig文件。本文主要介绍K......
  • Docker容器之——Docker常用命令
    1.docker帮助命令dockerversion#显示docker版本信息dockerinfo#显示docker信息系统,包括镜像和容器数量docker--help#docker帮助命令2.docker镜像命令docke......
  • 【kafka源码】ReassignPartitionsCommand分区副本重分配源码原理分析(附配套教学视频)
    日常运维、问题排查​​滴滴开源LogiKM一站式Kafka监控与管控平台​​​​阿B:石臻臻的杂货铺​​文章目录​​1.脚本的使用​​​​2.源码解析​​​​2.1`--generate`......
  • 使用 Bitnami Helm 安装 Kafka
    服务器端K3S上部署KafkaServerKafka安装......