CentOS7上如何安装Kafka?CentOS7上安装Kafka教程

简介

Kafka 是一种高吞吐的分布式发布订阅消息系统,能够替代传统的消息队列用于解耦合数据处理,缓存未处理消息等,同时具有更高的吞吐率,支持分区、多副本、冗余,因此被广泛用于大规模消息数据处理应用

Kafka 支持Java 及多种其它语言客户端,可与Hadoop、Storm、Spark等其它大数据工具结合使用。

本教程主要介绍Kafka 在Centos 7上的安装和使用,包括功能验证和集群的简单配置。

安装JDK

Kafka 使用Zookeeper 来保存相关配置信息,Kafka及Zookeeper 依赖Java 运行环境,从oracle网站下载JDK 安装包,解压安装:

$tar zxvf jdk-8u65-linux-x64.tar.gz
$mv jdk1.8.0_65 java

设置Java 环境变量:

JAVA_HOME=/opt/java
PATH=$PATH:$JAVA_HOME/bin
export JAVA_HOME PATH

也可以选择yum install安装,相应设置环境变量。

安装Kafka

从官网下载Kafka 安装包,解压安装: 官网地址:http://kafka.apache.org/downloads.html

tar zxvf kafka_2.11-0.8.2.2.tgz
mv kafka_2.11-0.8.2.2 kafka
cd kafka

功能验证

1.启动Zookeeper 使用安装包中的脚本启动单节点Zookeeper 实例:

bin/zookeeper-server-start.sh -daemon config/zookeeper.properties

2.启动Kafka 服务 使用kafka-server-start.sh 启动kafka 服务:

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

3.创建topic 使用kafka-topics.sh 创建单分区单副本的topic test:

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

查看topic:

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

4.产生消息 使用kafka-console-producer.sh 发送消息:

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

5.消费消息 使用kafka-console-consumer.sh 接收消息并在终端打印:

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

producer产生的消息和consumer消费的消息是同步的。

(0)

相关推荐

  • 一体机Realtek网卡安装联想网站上的网卡驱动报错的解决方案

    故障现象: Realtek网卡的一体机安装联想网站上的网卡驱动出现报错“The Realtek Network Controller was not found.If Deep Sleep Mode ...

  • 如何将下载的字体安装到电脑上(Win7/8/8.1通用)

    还在羡慕别人的文档、PS图片等打印出来的字体那么漂亮?其实这个很简单,我们只要从网上下载一些自己喜欢的字体,然后安装在电脑就可以实现。那么下载的字体怎么安装到电脑上呢?以下百事网小编为大家分享下Win ...

  • 将ipad软件安装到iphone上的技巧

    一般来说,ipad专属程序画面清晰分辨率高,名字或图标都带有HD标识。默认情况下是无法安装在iphone上的。 本教程就为大家介绍如何将ipad软件安装到iphone上。 但是还是有其他的方法,可以让 ...

  • ipa怎么安装 touch2 4.2.1上用的ipa软件及安装图文教程

    开篇: 因为在网上传了一些touch2和伪3固件4.2.1可用的软件,大家都来找我索取,并且有咨询越狱之后的安装方法大,那我就来简单说一下。在这里首先谢谢那些喜欢我收藏的软件的朋友,我在这里顺便也会分 ...

  • memcached安装在windows7上的问题及解决方法

    memcached安装在windows7上的问题: 通过cmd命令行进入到D:webEvememcached(下载后的解压目录) 运行 memcached.exe -d install 报错“ fai ...

  • 安卓系统如何把软件安装在内存卡上

    使用安卓系统手机的朋友经常会碰到手机内存不足的情况,本来手机内存就小,还把所有软件都安装在手机内,不仅会占用手机内存使得手机运行速度变慢,其实很多情况下我们可以把软件安装到外置SD卡上或者把已经安装在 ...

  • 字体丢失后如何再下载安装到电脑上?

    相信很多小伙伴都有遇到丢失字体的情况,这个时候我们该如何重新下载安装到电脑上呢?方法很简单,下面小编就来为大家介绍.具体如下:1. 首先,打开电脑上的浏览器搜索"字体下载",在搜索 ...

  • 电脑上怎么禁止某个软件的安装

    我们在使用电脑的时候,总有一些恶意软件反复安装,想要禁止安装该如何操作呢?今天就跟大家介绍一下电脑上怎么禁止某个软件的安装的具体操作步骤.1. 按键盘上的Win R组合键,调出运行窗口,输入gpedi ...

  • Realtek高清晰音频管理器怎么安装到电脑上

    今天小编介绍的是Realtek高清晰音频管理器怎么安装到电脑上.具体如下:1. 打开电脑,在桌面上找到[此电脑]图标双击打开2. 打开后,我们选择左侧[此电脑]出现电脑磁盘,双击打开圈出的[本地磁盘c ...

  • 电脑上的打印机驱动如何下载安装

    有的用户购买了打印机,为了在电脑上打印东西,因此需要在电脑上下载安装打印机驱动,但是却不知道如何下载安装,那么小编就来为大家介绍一下吧.具体如下:1. 第一步,双击或者右击打开浏览器软件,接着搜索并打 ...