Kafka运行环境(Ubuntu)

Kafka是由Apache软件基金会开发的一个开源流处理平台,由Scala和Java编写。Kafka是一种高吞吐量的分布式发布订阅消息系统,它可以处理消费者规模的网站中的所有动作流数据。

服务商信息:北京君云时代科技有限公司
支付方式:镜像

商品参数

ImageId
img-ath3snmj
操作系统
Ubuntu Server 18.04.1 LTS 64位
集成软件
jdk 1.8.0,zookeeper 3.4.14,kafka_2.11-2.1.0
版本
v3.2.2
依赖云服务
云服务器

商品介绍

【产品介绍】

操作系统版本:Ubuntu Server 18.04.1 LTS 64位
JDK版本: jdk 1.8.0
Zookeeper版本: zookeeper 3.4.14
Kafka版本:kafka_2.11-2.1.0

【面向对象】

有基于Kafka环境需求的云服务器用户。

【推荐配置】

1 核 CPU 1G 内存及以上云服务器

【定价指南】

该镜像暂不收费。

【产品说明】

1、系统首次初始化启动较慢,请耐心等待,如长时间连不上请进入管理控制台,远程管理终端查 看状态;
2、服务器管理员账户信息:Linux 系统 SSH 默认管理员账户为 ubuntu,默认密码为新购 云主机 或者初始化系统盘时所设置;
更多使用说明请参照 PDF 镜像使用指南;
3、Linux 系统的root用户密码为:wl6BN7IRX75GC9Tf

【使用指南】

1、镜像安装后,即可使用。
Kafka可能需要用到安全组端口80,9092,2181,请确保服务器已经放开这些端口。

2、登陆服务器后切换 root 用户,root用户密码为:wl6BN7IRX75GC9Tf

3、软件安装路径
运行环境, 开发运行环境, Kafka, 运行环境, Ubuntu
4、端口
Kafka使用的默认端口号为:9092
Zookeeper使用的默认端口号为:2181
5、配置文件路径
Kafka配置文件路径:/opt/kafka-*/config/server.properties
Kafka日志文件路径:/tmp/kafka-logs
Zookeeper配置文件路径:/opt/zookeeper/conf/zoo.cfg
Zookeeper日志文件:/tmp/zookeeper/log
6.、确保ZooKeeper已经启动
查看状态:# zkServer.sh statu
如果未启动,执行如下命令启动:
# cd /opt/zookeeper-3.4.14/bin/
# zkServer.sh start
7、启动ZooKeeper后,检查Kafka是否启动
查看Kafka服务进程是否已经启动:jps -l
如果未启动,执行如下命令启动:
#/opt/kafka_2.11-2.1.0/bin/kafka-server-start.sh/opt/kafka_2.11-2.1.0/config/server.properties &
8、结果演示
(1)创建一个分区数为1、副本因子为3的主题 topic-demo
#cd /opt/kafka_2.11-2.1.0
#/bin/kafka-topics.sh --zookeeper localhost:2181/kafka --create --topic topic-demo --replication-factor 1 --partitions 4 Created topic "topic-demo".
(2)生产者
打开一个shell终端,然后使用 bin/kafka-console-producer.sh --broker-list localhost:9092 --topic topic-demo 命令发送一条消息“Hello,Kafka!” 至主题topic-demo
运行环境, 开发运行环境, Kafka, 运行环境, Ubuntu
(3)消费者
打开一个shell终端,通过 bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topic-demo 命令来订阅主题 topic-demo
运行环境, 开发运行环境, Kafka, 运行环境, Ubuntu

【小提示】

1、如果启动Kafka后出现如下错误提示:
[2017-09-26 08:26:45,064] FATAL Exiting Kafka. (kafka.server.KafkaServerStartable)
[2017-09-26 08:26:45,069] INFO [Kafka Server 1], shutting down (kafka.server.KafkaServer)
解决方案:
(1)·删除 /tmp/kafka-logs;
(2)netstat -lnp|grep 9092;并且 kill pid;
(3)最后再重新启动下就ok了
#/opt/kafka_2.11-2.1.0/bin/kafka-server-start.sh/opt/kafka_2.11-2.1.0/config/ server.properties &


【声明】

1、镜像中如有收费软件,请根据软件官方说明购买使用版权,因版权问题产生的纠纷本公司概不负责。
2、镜像操作系统为公司定制,并经过反复测试验证,请参照商品详情中信息使用,免费镜像为客户体验使用,收费镜像为镜像制作费用,除镜像本身默认环境问题,均不含任何人工技术支持。
3、部分付费镜像有安全加固,但不保证服务器绝对安全,互联网中不存在绝对安全的服务器,请做好代码安全,并培养良好的使用习惯。

【售后问题】

1、如有软件不能正常使用的情况请联系在线技术支持,技术支持请优先选择在线客服;
2、如需在线技术支持,上云架构设计、数据迁移、云产品咨询、配置、云主机环境安装调试、故障排查、安全加固、安全测试、高并发测试、负载均衡、集群等等服务请参照本公司服务类产品说明联系技术咨询;

售后服务

为保障您的权益,请勿线下交易!90%的欺诈、纠纷、资金盗窃均由线下交易导致。腾讯云市场为您提供以下服务保障:

优质服务商家

严格准入 提供海量上云服务

7*8小时在线客服

全程在线咨询 助您安心购物

专业测试保证品质

安全监测 保障商品质量

售后无忧

不满意可退款 保障售后无忧