当前位置:首页 > 服务端 > Linux安装 kafka

Linux安装 kafka

2022年11月09日 22:15:55服务端10

linux 安装 kafka

之前参照一些博客,安装kafka都遇到了一些问题,最后还是跟着官网的步骤才解决问题,官方的才稳啊!目前仅仅是个单机版,学习用,集群还需再研究。
下载最新版kafka,当前最新版是kafka_2.13-2.6.0
按照官方给的提示去做,就可以了。此版本已自带zookeeper,无需单独安装zookeeper。

1、下载 最新的Kafka版本并解压缩:
$ tar -xzf kafka_2.13-2.6.0.tgz
$ cd kafka_2.13-2.6.0

2、运行以下命令以正确的顺序启动所有服务:
启动内置zookeeper:

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

打开另一个终端会话并启动kafka:

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

成功启动所有服务后,您将运行并可以使用基本的Kafka环境。

3、编写事件
编写第一个事件之前,必须创建一个topic主题。
打开另一个终端会话并运行

$ bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092

Kafka的所有命令行工具都有其他选项:kafka-topics.sh不带任何参数的命令即可显示使用情况信息。例如,它还可以向您显示 详细信息,例如 新主题的分区数:

$ bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092
Topic:quickstart-events  PartitionCount:1    ReplicationFactor:1 Configs:
    Topic: quickstart-events Partition: 0    Leader: 0   Replicas: 0 Isr: 0
  • 生产者创建主题
$ bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092
This is my first event
This is my second event
  • 消费者订阅主题
$ bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092

按ctrl+c即可结束。
此时生产者发布的消息,消费者就能看到。

注意:所有例子来源于官网http://kafka.apache.org/quickstart#quickstart_download,可至官网查看详情。

如果之前安装过kafka,如需重新安装,必须清除在config文件夹下的kafka配置文件server.properties中 log.dirs=*** 指定的路径下的所有文件(rm -rf ./*),然后重启kafka,以免kafka启动报错。

作者:大的梦想
来源链接:https://blog.csdn.net/qq_41838571/article/details/108006453

版权声明:
1、JavaClub(https://www.javaclub.cn)以学习交流为目的,由作者投稿、网友推荐和小编整理收藏优秀的IT技术及相关内容,包括但不限于文字、图片、音频、视频、软件、程序等,其均来自互联网,本站不享有版权,版权归原作者所有。

2、本站提供的内容仅用于个人学习、研究或欣赏,以及其他非商业性或非盈利性用途,但同时应遵守著作权法及其他相关法律的规定,不得侵犯相关权利人及本网站的合法权利。
3、本网站内容原作者如不愿意在本网站刊登内容,请及时通知本站(javaclubcn@163.com),我们将第一时间核实后及时予以删除。


本文链接:https://www.javaclub.cn/server/69189.html

分享给朋友:

“Linux安装 kafka” 的相关文章

windows下kafka搭建

windows下kafka搭建

一、什么是kafka Kafka是由Apache软件基金会开发的一个开源流处理平台,由Scala和Java编写。Kafka是一种高吞吐量的分布式发布订阅消息系统,它可以处理消费者规模的网站中的所有动作流数据, 功能相同的还有Rabbitmq 、ActiveMQ 。 二、术语介绍 Bro...

Kafka启动报错 : ERROR Processor got uncaught exception

Kafka启动报错 : ERROR Processor got uncaught exception

参照我之前的一篇博文Kafka学习之(二)Centos下安装Kafka安装了kafka并启动,状况并不像我之前最初的预期,报错了,并且我在当前Linux环境下安装的Java版本、Kafka版本都是和之前博文一样的,第一感觉难道是因为Linux(Centos)的版本不一致??? ...

SpringBoot进阶教程(六十二)整合Kafka

SpringBoot进阶教程(六十二)整合Kafka

在上一篇文章《Linux安装Kafka》中,已经介绍了如何在Linux安装Kafka,以及Kafka的启动/关闭和创建发话题并产生消息和消费消息。这篇文章就介绍介绍SpringBoot整合Kafka。 在上一篇文章《Linux安装Kafka》中,...

kafka入门及安装部署

kafka入门及安装部署

kafka入门及安装部署 kafka安装包下载 kafka简介及应用场景 简介 应用场景 kafka安装部署...

docker安装kafka

docker安装kafka

1.先pull zookeeper的镜像 docker pull wurstmeister/zookeeper:latest docker pull wurstmeister/kafka:latest 2.查看镜像 docker im...

windows安装kafka

windows安装kafka

一、下载kafka http://kafka.apache.org/downloads 选择二进制版本。 二、安装kafka 下载到本地后,将文件解压到本地磁盘下,该文件夹包括了所有相关的运行文件及配置文件,其子文件夹bin\w...

kafka安装部署(windows)

kafka安装部署(windows)

文章目录 前言 kafka安装部署(windows) 01 zookeeper中间件 安装部署 01::01 启动zook...

CentOs7 安装 Kafka 或 Docker 安装 Kafka

CentOs7 安装 Kafka 或 Docker 安装 Kafka

Kafka CentOs7 安装 安装zookeeper 安装 Kafka Docker 安装 安装zookeepe...

Kafka中错误:Unrecognized VM option ‘UseCompressedOops’ Error: Clould not create the Java Vritual Machine. Error: A fatal exception has occurres . Program will exit.

Kafka中错误:Unrecognized VM option ‘UseCompressedOops’ Error: Clould not create the Java Vritual Machine. Error: A fatal exception has occurres . Program will exit.

     错误的描述:   在kafka安装目录下,执行 $ bin/zookeeper-server-start.sh config/zookeeper.properties &    Unrecognized VM op...

kafka安装使用

kafka安装使用

 先来说下kafka是个什么东西,它是一个消息中间件框架,只负责发布--订阅(帮忙存东西的)接着给大家看一张大致的kafka流程图         首先打个比方,kafka...

发表评论

访客

◎欢迎参与讨论,请在这里发表您的看法和观点。