linux查看远程kafka安装目录,Linux系统中KafKa安装和使用方法

本文以0.10.0.1版本的kafka为例

1 下载并安装kafka# wget http://apache.fayea.com/kafka/0.10.0.1/kafka-0.10.0.1-src.tgz

# tar zxvf kafka-0.10.0.1-src.tgz

# mv kafka-0.10.0.1-src /usr/local/kafka

# cd !$

2 启动服务

运行kafka需要使用Zookeeper，所以需要先启动一个Zookeeper服务器，如果没有Zookeeper，可以使用kafka自带打包和配置好的Zookeeper# bin/zookeeper-server-start.sh config/zookeeper.properties

然后启动kafka服务# bin/kafka-server-start.sh config/server.properties &

3 新建一个topic

创建一个名为“test”的Topic，只有一个分区和一个备份：# bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

创建好之后，可以通过以下命令查看已创建的topic信息：# bin/kafka-topics.sh --list --zookeeper localhost:2181test

除手工创建topic外，也可以配置broker，当发布一个不存在的topic时自动创建topic。

4 发送消息

Kafka提供了一个命令行工具，可以从输入文件或者命令行中读取消息并发送给Kafka集群，每一行是一条消息。运行producer,然后在控制台输入几条消息到服务器# bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

This is a message

This is another message

5 消费消息

Kafka也提供了一个消费消息的命令行工具# bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

This is a message

This is another message

更多使用说明请参考官方文档

linux查看远程kafka安装目录,Linux系统中KafKa安装和使用方法相关推荐

linux查看所有用户家目录,linux – 允许用户读取其他用户的主目录
我是系统管理的新手,我有一个与权限相关的查询.我有一个叫做管理的小组.在管理组内部,我有用户user1,user2,user3,超级用户.所有用户都在管理组中.现在,我需要为用户超级用户授予权限,以便 ...
centos php 默认安装目录,centos系统中的软件安装目录在哪
centos系统中软件的默认安装目录一般在/usr/local或者/opt中. 我们还可以通过whereis命令来查看软件的实际安装路径. 命令:whereis 功能介绍:在特定目录中查找符合条件的文 ...
linux 查看u盘挂载目录,Linux下手动挂载U盘
在电脑上直接插入U盘,其实是可以直接使用的,会自动弹出一个窗口,不会像网上所说的那样,必须要自己挂载,但是为了学习手动用命令行挂载U盘,我关掉了那个窗口.可以用df –h查看文件系统的磁盘空间占用情况 ...
linux怎么使用git安装目录,Linux系统中怎么安装Git？
Linux Git是一个方便可用的管理器工具,起初Git就是为Linux而开发的,现在已经应用到各大系统中了.本文就来介绍一下Linux系统中怎么安装Git. 使用包管理器安装Git Git已经被所有 ...
linux java的安装目录,linux java 安装目录
linux java 安装目录 [2021-02-01 05:04:30] 简介: php去除nbsp的方法:首先创建一个PHP代码示例文件:然后通过"preg_replace(" ...
远程连接linux服务器文件共享,linux mount 远程服务器共享目录
NFS是文件系统.在网络存储方面我们应该有所了解.那么针对NFS服务器的安装和设置我们来详细介绍一下.首先让我们看一下NFS服务器的安装步骤. 一.NFS服务器的安装检查linux系统中是否安装了n ...
linux查看远程服务器端口,linux下查看本机和远程服务器的端口是否连通的方法...
linux下查看本机和远程服务器的端口是否连通的方法如下所示: 1.ssh -v -p [端口号] [用户名]@[IP地址] 2.curl [IP地址]:[端口号] 以上这篇linux下查看本机和远 ...
在Linux系统中的安装cpolar内网穿透
系列文章将cpolar内网穿透配置为开机自启动在Linux系统中的安装cpolar内网穿透 linux本地搭建网站,并将其发布到公网可访问 1-8 linux本地搭建网站,并将其发布到公网可访问 ...
深度linux运行windows游戏,在deepin linux系统中手动安装windows游戏的小技巧
本文介绍在deepin linux系统中手动安装windows游戏的小技巧.其实现在wine很好用了,基本dx9的游戏都能玩,但是有些RA2则效果一般,不是很好.关于deepin-wine的版本低有些 ...
linux下ace安装教程,Linux 系统中如何安装配置ACE
Linux 系统中如何安装配置ACE http://www.gnu.org可以下载ACE安装包,这里以ACE-5.6.tar.gz安装包作为示例 1.设置$ACE_ROOT环境变量 # vim /et ...

linux查看远程kafka安装目录,Linux系统中KafKa安装和使用方法

linux查看远程kafka安装目录,Linux系统中KafKa安装和使用方法相关推荐

最新文章

热门文章