文档章节

kafka相关命令

 李浩_
发布于 2016/09/20 16:53
字数 77
阅读 79
收藏 1
# 启动zookeeper
./bin/zookeeper-server-start.sh config/zookeeper.properties &
# 启动kafka
./bin/kafka-server-start.sh config/server.properties &


# 后台启动zookeeper
./bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
# 后台启动kafka
./bin/kafka-server-start.sh -daemon config/server.properties


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

# 创建product
./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

# 启动消费者
./bin/kafka-console-consumer.sh --zookeeper hadoop:2181 --topic test

 

© 著作权归作者所有

上一篇: 微信开发者工具
下一篇: 搭建spark 集群
粉丝 2
博文 15
码字总数 9606
作品 0
北京
高级程序员
私信 提问
kafka安装配置

Kafka主要构成: 1、Broker:集群中的每一个对应的服务器被称之为broker。 2、Topic 用于区别消息的类别,每个topic中包含多个Partition;Partition主要可以减少每个日志的数据量,也可以增加...

halbert918
2016/01/22
229
0
Consumer is not subscribed to any topics

产生该问题的原因主要是中存在旧版本的信息,导致新版本的启动异常: 解决办法: (1) 使用命令列出所有与相关的: 输出: (2)使用命令删除所有与相关的: 最后验证是否删除: 输出: 输出...

九州暮云
2018/08/11
1K
0
spark-submit提交Spark Streamming+Kafka程序

我的原创地址:https://dongkelun.com/2018/06/19/sparkSubmitKafka/ 前言 Spark Streaming本身是没有Kafka相关的jar包和API的,如果想利用Spark Streaming获取Kafka里的数据,需要自己将依赖...

董可伦
2018/07/12
0
0
Linux系统Kafka集群搭建与简单测试

Kafka安装 Zookeeper集群搭建,可参考Linux系统Zookeeper集群配置 上传kafka安装包并解压 编辑配置文件 这个是server.properties文件内容 增加集群的配置文件server1.properties 修改配置 增...

Listen_ing
2016/06/02
843
0
java B2B2C源码电子商城系统-Kafka快速入门

大家对Kafka有了一些基本了解之后,下面我们来尝试构建一个Kafka服务端,并体验一下基于Kafka的消息生产与消费。 需要JAVA Spring Cloud大型企业分布式微服务云构建的B2B2C电子商务平台源码 ...

明理萝
03/18
25
1

没有更多内容

加载失败,请刷新页面

加载更多

RxJava进行单元测试的方式

@Test public void completeTask_retrievedTaskIsComplete() { // Given a new task in the persistent repository final Task newTask = new Task(TITLE, ""); ......

SuShine
9分钟前
2
0
正则表达式大全

检验手机号码 # 要求:手机号码必须为11位数字,以1开头,第二位为1或5或8。import redef verify_mobile(): mob = input("请输入手机号码:") ret = re.match(r"1[358]\d{9}", m......

彩色泡泡糖
13分钟前
2
0
QT之border-image属性

一、border-image的兼容性 border-image可以说是CSS3中的一员大将,将来一定会大放光彩,其应用潜力真的是非常的惊人。可惜目前支持的浏览器有限,仅Firefox3.5,chrome浏览器,Safari3+支持...

shzwork
13分钟前
2
0
Kubernetes Operator简易教程

1. 安装operator-sdk //安装 operator-sdk$ apt-get install operator-sdk.....$ operator-sdk versionoperator-sdk version: v0.7.0$ go versiongo version go1.11.4 darwin/amd64 2......

Robotcl_Blog
13分钟前
3
0
再谈DAG任务分解和Shuffle RDD

1、DagScheduler分析 DagScheduler功能主要是负责RDD的各个stage的分解和任务提交。Stage分解是从触发任务调度过程的finalStage开始倒推寻找父stage,如果父stage没有提交任务则循环提交缺失...

守望者之父
19分钟前
2
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部