kafka 命令笔记

以下命令都是在kafka根目录下

启动自带的zookeeper
```
bin/zookeeper-server-start.sh config/zookeeper.properties
```
启动kafka
(启动完zookeeper后，应再新开个窗口启动kafka,不然会报超时错误，可能由于我用的linux命令有问题，ctrl+z让它后台运行，没有起作用。回头在研究一下)

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

查看所有的topic相信信息（描述）

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

查看所有的topic列表

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

、w

时间： 2024-10-22 05:06:27

kafka 命令笔记的相关文章

linux命令笔记

3步实现ssh login不用密码: 1 ssh-keygen (Create public and private keys) 2 ssh-copy-id -i ~/.ssh/id_rsa.pub remote-host (Copy the public key to remote-host) 3 ssh remote-host (不用密码了) linux命令笔记,布布扣,bubuko.com

linux基础命令--笔记一. 1 . --help 命令简单帮助 2. man 查看命令复杂帮助 (非内置命令) 3 . help (bash的内置命令)如 :help cd .help pwd help 内置命令可用man cd 等查看. 4 . ls==list 查看目录列表 5 . mkdir == make directory 创建目录.例如:mkdir /date -p 递归创建目录 :mk 6 . cd ==change directo

hexo常用命令笔记

hexo npm install -g hexo npm update -g hexo hexo init 常用 hexo n == hexo new "a new post" 新建文章,最好用双引号括起来 hexo g == hexo generate 生成静态文件到public文件夹 hexo s == hexo server Server at localhost:4000,根目录为public hexo d == hexo deploy 部署到远程服务里,例如github he

lunux命令笔记

文件查看命令 ls / -lh ls list / 路径 -l 详细 -lh 详细的人性化显示 -ld 显示目录 -i 显示i节点 mkdir /tmp/mulu/mulu2 /tmp/ma/mb -p -p 递归创建目录目录处理命令 cd /tmp 进入目录 cd .. 返回上一级目录 pwd 显示当前所在目录 cp -r [原文件或目录] [目标文件或目录] cp 复制 -r 复制目录 -p 保存原来文件的属性 mv [原文件或目录] [目标文件或目录] mv 移动或剪切文件处理命令 r

Linux/Unix mac 命令笔记

bg和fg Linux/Unix 区别于微软平台最大的优点就是真正的多用户,多任务.因此在任务管理上也有别具特色的管理思想.我们知道,在 Windows 上面,我们要么让一个程序作为服务在后台一直运行,要么停止这个服务.而不能让程序在前台后台之间切换.而 Linux 提供了 fg 和 bg 命令,让你轻松调度正在运行的任务. 假设你发现前台运行的一个程序需要很长的时间,但是需要干其他的事情,你就可以用 Ctrl-Z ,挂起这个程序,然后可以看到系统提示:[1]+ Stopped /root/bi

Ant-常用命令(笔记二)

1.copy命令: <?xml version="1.0" encoding="utf-8"?> <project name="copyFile" default="copyToOtherPath">  <target name="copyTaget"> <copy file="mmmt.txt" tofi

Kafka学习笔记（一）：概念介绍

Kafka是一个开源的,分布式的,高吞吐量的消息系统.随着Kafka的版本迭代,日趋成熟.大家对它的使用也逐步从日志系统衍生到其他关键业务领域.特别是其超高吞吐量的特性,在互联网领域,使用越来越广泛,生态系统也越来的完善.同时,其设计思路也是其他消息中间件重要的设计参考. Kafka原先的开发初衷是构建一个处理海量日志的框架,基于高吞吐量为第一原则,所以它对消息的可靠性以及消息的持久化机制考虑的并不是特别的完善.0.8版本后,陆续加入了一些复制.应答和故障转移等相关机制以后,才可以让我们在其他关

kafka学习笔记：知识点整理（二）

三.kafka HA 3.1 replication 如图.1所示,同一个 partition 可能会有多个 replica(对应 server.properties 配置中的 default.replication.factor=N).没有 replica 的情况下,一旦 broker 宕机,其上所有 patition 的数据都不可被消费,同时 producer 也不能再将数据存于其上的 patition.引入replication 之后,同一个 partition 可能会有多个 replic

kafka学习笔记：知识点整理

一.为什么需要消息系统 1.解耦: 允许你独立的扩展或修改两边的处理过程,只要确保它们遵守同样的接口约束. 2.冗余: 消息队列把数据进行持久化直到它们已经被完全处理,通过这一方式规避了数据丢失风险.许多消息队列所采用的"插入-获取-删除"范式中,在把一个消息从队列中删除之前,需要你的处理系统明确的指出该消息已经被处理完毕,从而确保你的数据被安全的保存直到你使用完毕. 3.扩展性: 因为消息队列解耦了你的处理过程,所以增大消息入队和处理的频率是很容易的,只要另外增加处理过程即可. 4.