首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >专栏 >kafka基本操作(一) linux环境下一个broker

kafka基本操作(一) linux环境下一个broker

作者头像
六月的雨在Tencent
发布于 2024-03-28 11:21:34
发布于 2024-03-28 11:21:34
11700
代码可运行
举报
文章被收录于专栏:CSDNCSDN
运行总次数:0
代码可运行

kafka基本操作(一) linux环境下一个broker

1.下载:kafka官网 http://kafka.apache.org/downloads下载到最新的kafka安装包

2.启动服务:

  • 首先启动zookeeper服务:
代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
//cd进入kafka解压目录,输入
[root@localhost kafka_2.11-1.1.0]#./bin/zookeeper-server-start.sh config/zookeeper.properties
  • 启动kafka:
代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
//cd进入kafka解压目录,输入
[root@localhost kafka_2.11-1.1.0]#./bin/kafka-server-start.sh config/server.properties

Kafka通过topic对同一类的数据进行管理,同一类的数据使用同一个topic可以在处理数据时更加方便快捷。

3.新建一个topic:

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
//cd进入kafka解压目录,输入
[root@localhost kafka_2.11-1.1.0]#./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test01

4.查看已经存在的Topic列表:

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
//cd进入kafka解压目录,输入
[root@localhost kafka_2.11-1.1.0]#./bin/kafka-topics.sh --list --zookeeper localhost:2181

5.新建一个消息生产者:

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
//cd进入kafka解压目录,输入
[root@localhost kafka_2.11-1.1.0]#./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test01

6.新建一个消息消费者:

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
//cd进入kafka解压目录,输入
[root@localhost kafka_2.11-1.1.0]#./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test01 --from-beginning
本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2018-04-18,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
暂无评论
推荐阅读
编辑精选文章
换一批
kafka基本操作(二) linux环境下多个broker
六月的雨在Tencent
2024/03/28
2660
kafka基本操作(二) linux环境下多个broker
Kafka单机环境搭建简记
最近在搞kettle整合kafka producer插件,于是自己搭建了一套单机的kafka环境,以便用于测试。现整理如下的笔记,发上来和大家分享。后续还会有kafka的研究笔记,依然会与大家分享!
星哥玩云
2022/07/26
1.5K0
Kafka单机环境搭建简记
Kafka安装启动入门教程
本文讲如何安装启动kafka,并进行测试,其中zookeepr是kafka自带的,本文基本按照官网文档进行安装启动的,并提出可能会出现的问题。官方文档:http://kafka.apache.org/quickstart 本文虚拟机系统:centos7,不过其他版本的Linux系统是一样的~
小明互联网技术分享社区
2022/10/31
1.1K2
Kafka安装启动入门教程
kafka 集群配置_kafka集群原理
kafka是一个高吞吐的分布式消息队列系统。特点是生产者消费者模式,先进先出(FIFO)保证顺序,自己不丢数据,默认每隔7天清理数据。消息列队常见场景:系统之间解耦合、峰值压力缓冲、异步通信。
全栈程序员站长
2022/09/27
1.3K0
安装单机kafka
安装jdk 安装kafka [root@localhost kafka_2.11-1.0.0]# wget http://mirrors.shuosc.org/apache/kafka/1.0.0/kafka_2.11-1.0.0.tgz [root@localhost kafka_2.11-1.0.0]# cd kafka_2.11-1.0.0/ #启动zookeeper [root@localhost kafka_2.11-1.0.0]# bin/zookeeper-server-start.sh -d
零月
2018/04/25
1.2K0
安装单机kafka
Kafka 单机部署
Kafka 单机部署区分集成Zookeeper 部署和Zookeeper + Kafka 部署俩总方式,如果是单机部署Kafka,集成Zookeeper 最简单,也可以选择Zookeeper + Kafka 这种模式,但是如果为Kafka集群的话,则必须需要部署 Zookeeper 集群。
Freedom123
2024/03/29
1840
kafka 入门
kafka是一个分布式消息队列。具有高性能、持久化、多副本备份、横向扩展能力。生产者往队列里写消息,消费者从队列里取消息进行业务逻辑。一般在架构设计中起到解耦、削峰、异步处理的作用。 Kafka安装配置
句小芒
2022/12/29
4830
kafka 入门
kafka安装与测试
Producer即生产者,向Kafka集群发送消息,在发送消息之前,会对消息进行分类,即Topic, Topic即主题,通过对消息指定主题可以将消息分类,消费者可以只关注自己需要的Topic中的消息 Consumer即消费者,消费者通过与kafka集群建立长连接的方式,不断地从集群中拉取消息,然后可以对这些消息进行处理。
瑾诺学长
2018/09/21
1.8K0
kafka集群搭建
RabbitMQ是使用Erlang编写的一个开源的消息队列,本身支持很多的协议:AMQP,XMPP, SMTP, STOMP,也正因如此,它非常重量级,更适合于企业级的开发。同时实现了Broker构架,这意味着消息在发送给客户端时先在中心队列排队。对路由,负载均衡或者数据持久化都有很好的支持。
Cyylog
2020/08/19
7780
KAFKA的安装配置
用户1171305
2017/12/28
9930
KAFKA的安装配置
Apache Kafka-初体验Kafka(02)-Centos7下搭建单节点kafka_配置参数详解_基本命令实操
由于Kafka是用Scala语言开发的,运行在JVM上,因此在安装Kafka之前需要先安装JDK.
小小工匠
2021/08/17
5680
kafka介绍和常见操作
RabbitMQ:支持消息的可靠的传递,支持事务,不支持批量操作,基于存储的可靠性的要求存储可以采用内存或硬盘,吞吐量小。
章工运维
2023/05/19
3300
Kafka安装(极简版)
kafka是一个高吞吐量的分布式消息队列,具有高性能、持久化、多副本备份、横向扩展能力,通常用于大数据及流处理平台。消息队列里都有生产者/消费者的概念,生产者往队列里写消息,而消费者则是从队列里获取消息。一般在架构设计中起到解耦、削峰、异步处理的作用。
端碗吹水
2020/09/23
4530
Kafka安装(极简版)
Kafka 单节点单Kafka Broker集群
下载与安装 从 http://www.apache.org/dist/kafka/ 下载最新版本的 kafka,这里使用的是 kafka_2.12-0.10.2.1.tgz $ tar zxvf kafka_2.12-0.10.2.1.tgz $ cd kafka_2.12-0.10.2.1 运行 启动 zookeeper 服务 $ bin/zookeeper-server-start.sh config/zookeeper.properties 启动 kafka Broker 服务 $ bin/kafka
kongxx
2018/05/14
8410
启动kafka服务并用golang发送和接受消息
kafka系列分为两个篇幅,分别是实用篇,讲使用命令和一些使用中会遇到的概念名词,理论篇,讲kafka为了实现高可用和高性能做了哪些努力。这篇我们从搭建开始,然后用kafka脚本去发送和接受信息,最后用go语言展示在代码之中怎么使用。
用户7962184
2020/11/20
3K0
KafKa(0.10)安装部署和测试
Step 1: 下载代码 http://kafka.apache.org/downloads.html 0.10.0.0是最新版本。 当前的稳定版本是0.10.0.0。 下载0.10.0.0版本并且解压它。 > tar -zxvf kafka_2.10-0.10.0.0.tgz  > cd kafka_2.11-0.10.0.0 Step 2: 启动服务 运行kafka需要使用Zookeeper,所有你需要先启动一个Zookeeper服务器,如果你没有Zookeeper,你可以使用kafka自带打包
汤高
2018/01/11
1.4K0
teg kafka安装和启动
kafka的背景知识已经讲了很多了,让我们现在开始实践吧,假设你现在没有Kafka和ZooKeeper环境。
葫芦
2019/10/16
7230
【kafka学习笔记】 第三天--kafka的安装和使用
kafka是由scala语言写成的,后面用Java重构了,但是不管怎样,都要编译到jvm虚拟机中执行。
玖柒的小窝
2021/12/10
3190
【kafka学习笔记】 第三天--kafka的安装和使用
技术分享 | Apache Kafka下载与安装启动
壹 下载 注意:别下成源文件了! 带src的是源文件,如: Source download: kafka-0.10.1.0-src.tgz (asc, md5) 你应该下的是: Scala 2.11 - kafka_2.11-0.10.1.0.tgz (asc, md5) 推荐下载scala 2.11版本的 你可以登录Apache kafka 官方下载。 http://kafka.apache.org/downloads.html 贰 安装与启动 kafka的背景知识已经讲了很多了,让我们现在开始实践吧,假
加米谷大数据
2018/04/02
2.4K0
进击消息中间件系列(三):Kafka 中 shell 命令使用
注:partitions指定topic分区数,replication-factor指定topic每个分区的副本数。
民工哥
2023/08/22
5910
进击消息中间件系列(三):Kafka 中 shell 命令使用
相关推荐
kafka基本操作(二) linux环境下多个broker
更多 >
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档