1单机 安装
安装过程,参考官网:
> tar xzf kafka-<VERSION>.tgz > cd kafka-<VERSION> > ./sbt update > ./sbt package > ./sbt assembly-package-dependency
出现问题
1 在安装 0.8 版本时,出现如下问题
ead "main" java.lang.NoClassDefFoundError: org/apache/zookeeper/server/quorum/QuorumPeerMain
Caused by: java.lang.ClassNotFoundException: org.apache.zookeeper.server.quorum.QuorumPeerMain
at java.net.URLClassLoader$1.run(URLClassLoader.java:202)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:190)
at java.lang.ClassLoader.loadClass(ClassLoader.java:306)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301)
at java.lang.ClassLoader.loadClass(ClassLoader.java:247)
按照 http://www.bdfindustries.com/blog/2012/02/11/getting-started-with-apache-kafka/这位仁兄的方法没有解决
2安装0.7,出现如下问题
[error] Note: Some input files use or override a deprecated API. [error] Note: Recompile with -Xlint:deprecation for details.
忽略掉 ,继续执行
2 单机使用
上面的步骤都执行完了,环境算是好了,下面我们要测试下是否能成功运行kafka:
1. 启动zookeeper server :bin/zookeeper-server-start.sh ../config/zookeeper.properties & (用&是为了能退出命令行)
2. 启动kafka server: bin/kafka-server-start.sh ../config/server.properties &
3. Kafka为我们提供了一个console来做连通性测试,下面我们先运行producer:bin/kafka-console-producer.sh --zookeeper localhost:2181 --topic test 这是相当于开启了一个producer的命令行。命令行的参数我们一会儿再解释。
4. 接下来运行consumer,新启一个terminal:bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
5. 执行完consumer的命令后,你可以在producer的terminal中输入信息,马上在consumer的terminal中就会出现你输的信息。有点儿像一个通信客户端。
如果你能看到5执行了,说明你单机版部署成功了。下面解释下两条命令中参数的意思。--zookeeper localhost:2181 这个说明了去连本机2181端口的zookeeper server,--topic test,在kafka里,消息按topic来区分,我们这里的topic叫test,所以不管是consumer还是producer都指向了test。其他的参数,我就截图了,首先是producer的参数:
以上转载参考自:http://my.oschina.net/ielts0909/blog/93190
3 集群安装使用
类似单机,参考如下网址:http://my.oschina.net/ielts0909/blog/93190
相关推荐
kafka单机版安装部署手册1
kafka单机版自动安装shell脚本、kafka_2.13-2.8.0.tgz、apache-zookeeper-3.6.3-bin.tar.gz
kafka 配置 kerberos,设置 ACL权限, java 客户端连接。
Kafka是一个分布式的、可分区的、可复制的消息系统。它提供了普通消息系统的功能,但具有自己独特的设计。这个独特的设计是什么样的呢
本文不讲kafka集群原理,只谈部署步骤。 默认读者已对kafka有最基本的认知,纯粹作为部署笔记,方便回忆。 另外本文是基于Windows部署的,Linux的步骤是基本相同的(只是启动脚本位置不同)。 kafka集群类型: ...
kubernetes 部署单机版Kafka、zookeeper
CentOS6.5下kafka+ZooKeeper下载与安装详细教程-单机版
Kafka安装部署与Java调用(内含单机版、集群版)
项目需要,自学初级kafka环境搭建,现将学习心得,解压包和样例代码上传供大家参考学习,有兴趣的可以私聊讨论。
Kafka学习笔记,包括Kafka术语、学习过程中单机版Kafka安装与配置、基于Docker的Kafka集群安装与配置、kafka消息机制与原理、学习方法
Kafka Manager 是 Yahoo 推出的 Kafka 管理工具,支持:管理多个集群轻松检查集群状态 (topics, brokers, replica distribution, partition distribution)执行复制选举生成分区指派,基于集群的状态分区的重新指派该...
分别介绍了kafka单机版,集群版环境搭建和常用配置和命令,并有和spring整合开发的简单示例。
超级账本 fabric 1.0 单机 kafka 配置 yaml 用于超级账本fabric配置
kafka模拟生产者、消费者,集群模式,若是单机版,将ip端口组改为相应ip端口即可;
windows 单机版 kafka 搭建-附件资源
Dockerfile base java Zookeeper RocketMQ Dockerfile 安装 RocketMQ 单机版 Dockerfile 安装 RocketMQ 集群版 Kafka Dockerfile 安装 Kafka 单机版
主要给大家介绍了关于Kafka源码系列教程之删除topic的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧