文档章节

Kafka安装和消息操作

夜雨寄北09
 夜雨寄北09
发布于 2017/07/24 17:17
字数 376
阅读 34
收藏 1

下载

下载地址:http://kafka.apache.org/downloads

当前最新版本为0.11.0.0,建议下载 kafka_2.11-0.11.0.0.tgz

解压

tar -xzf kafka_2.11-0.11.0.0.tgz
cd kafka_2.11-0.11.0.0

启动服务

Kafka使用ZooKeeper,首先需要启动Zookeeper,Kafka内置了Zookeeper,可以用命令启动一个单节点Zookper:

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

Zookeeper默认端口为2181,可在zookeeper.properties中修改。

开启一个新的终端,启动Kafka:

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

创建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:2181

相对于手动创建topic,也可以设置当发送信息到不存在的topic时,自动创建topic。

查看topic明细:

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

删除topic:

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

永久删除topic:
删除kafka存储目录(server.properties文件log.dirs配置,默认为"/tmp/kafka-logs")相关topic目录 
删除zookeeper "/brokers/topics/"目录下相关topic节点
cd /usr/lib/zookeeper,或 cd <zookeeper安装目录>
bin/zkCli.sh -server 127.0.0.1
ls /brokers/topics/test
rmr /brokers/topics/test
rmr /admin/delete_topics/test

发送消息

开启一个新的终端,启动一个消息生产者:

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

发送消息:

This is a message
This is another message

接收消息

开启一个新的终端,启动一个消费者:

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

可以看到接收到的消息。

停止Kafka服务

bin/kafka-server-stop.sh
bin/zookeeper-server-stop.sh

 

© 著作权归作者所有

共有 人打赏支持
夜雨寄北09
粉丝 7
博文 16
码字总数 11686
作品 0
浦东
程序员
架构设计:系统间通信(28)——Kafka及场景应用(中1)

(接上文《架构设计:系统间通信(27)——其他消息中间件及场景应用(上)》) 在本月初的写作计划中,我本来只打算粗略介绍一下Kafka(同样是因为进度原因)。但是,最近有很多朋友要求我详...

yinwenjie
2016/05/02
0
0
Kafka(二):Kafka安装与使用

一、安装Kafka 官方快速安装文档:http://kafka.apache.org/quickstart 安装kafka 启动zookeeper服务 启动kafka服务 二、Kafka操作 1. 创建Topic 创建一个名叫kafka_test, 一个复制因子一个...

saytime
04/15
0
0
【Kafka源码】Kafka代码模块

Kafka源码依赖于Scala环境,首先需要安装scala,这块请自行百度进行安装。 传送门 当然,我们要分析源码,需要下载源码,请自行从github上面下载。 说明:本文使用的kafka版本为0.10.0.1,这...

端木轩
2017/10/23
0
0
Spring Boot集成Kafka

Spring Boot集成Kafka Spring Boot集成Kafka 前提介绍 Kafka Kafka安装与使用 Spring Boot集成 总结 参考资料 前提介绍 由于公司使用了微服务架构,很多业务拆成了很多小模块。 有个场景是这...

流水不腐小夏
2017/11/26
0
0
Kafka安装与简介

今天来讲一下Kafka,它是一个消息队列,应用场景比较广泛。刚开始学习一门东西,咱们先不管它是干什么的,先跑起来才是正经,所以本文主要讲两点: 安装搭建Kafka 简单介绍下Kafka的原理和应...

Trigl
2017/05/23
0
0

没有更多内容

加载失败,请刷新页面

加载更多

win32截屏并rgb24转yuv420

//最终f的内存布局为BGRA格式,需要保证buf长度足够(>w*h*4)void ScreenCap(void* buf, int w, int h){ HWND hDesk = GetDesktopWindow(); HDC hScreen = GetDC(hDesk); ......

styleman
54分钟前
1
0
php输出mysql取出的中文为??的问题

解决方法: @ $db=new mysqli(DB_HOST,DB_USER,DB_PASSWORD,DB_DB); $db->query("set names utf8");//添加此语句,可以解决问题...

Aomo
今天
1
2
白话SpringCloud | 第五章:服务容错保护(Hystrix)

前言 前一章节,我们知道了如何利用RestTemplate+Ribbon和Feign的方式进行服务的调用。在微服务架构中,一个服务可能会调用很多的其他微服务应用,虽然做了多集群部署,但可能还会存在诸如网...

oKong
今天
2
0
【解惑】领略Java内部类的“内部”

内部类有两种情况: (1) 在类中定义一个类(私有内部类,静态内部类) (2) 在方法中定义一个类(局部内部类,匿名内部类) 1、私有内部类 —— 在方法之间定义的内部类,非静态 我们首先看看类中...

偶尔诗文
今天
1
0
sqlserver 2008 r2 直接下载地址(百度云)

之前下载的sqlserver2008发现不能附加,就卸载了,重新找到了sqlserver2008R2的百度云资源 卸载sqlserver2008还是有点麻烦,不过就是需要删除注册表中的信息 自己来回卸载了3次终于重装sqlse...

dillonxiao
今天
3
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部