安装启动kafka

vim kafka/config/server.properties

#确保唯一
broker.id=0
#允许删除主题
delete.topic.enable=true
# 指定数据文件所在目录
log.dirs=/var/local/kafka/logs
#zookeeper 的连接地址
zookeeper.connect=localhost:2181

启动kafka

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

#查看进程,带上全类名

jps -l

#创建主题,一个分区,一个备份

bin/kafka-topics.sh --create --zookeeper localhost:2181 --partitions 1 --replication-factor 1 --topic first

#查看kafka的主题

bin/kafka-topics.sh --list --zookeeper localhost:2181

#生产者产生数据

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

#启动消费者

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic first --from-beginning

不跟zk交互,改跟kafka交互,提高效率

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

原文地址:https://www.cnblogs.com/dongma/p/9912348.html

时间: 2024-10-10 22:47:34

安装启动kafka的相关文章

Linux下安装并(单节点)配置启动Kafka

1. 从Kafka官网下载最新的Kafka,目前最新版本为0.9.0.1 2. 下载完毕后,上传到Linux服务器,并解压  tar -xzf kafka_2.11-0.9.0.1.tgz 3. 修改Zookeeper服务器配置,并启动 cd kafka_2.11-0.9.0.1 vi config/zookeeper.properties  #修改ZooKeeper的数据目录 dataDir=/opt/favccxx/db/zookeeper #配置host.name和advertised.h

Windows安装运行Kafka

简介 本文讲述了如何在Windows OS上配置并启动Apache Kafka,这篇指南将会指导你安装Java和Apache Zookeeper. Apache Kafka是一个快速可扩展的消息队列,能够应对繁重的读写负载,即IO相关工作.更多信息请参见http://kafka.apache.org.由于Zookeeper能提供可靠的分布式协调服务,Apache Kafka需要运行一个Zookeeper实例.更多Zookeeper的相关信息请查看https://zookeeper.apache.

安装部署Kafka集群

kafka是一个开源的分布式消息订阅系统(消息中间件) 安装过程 1.下载kafka_2.11-0.10.1.0.gz(ps:千万不要下错了,博主就是下到了src文件上去了,kafka中的zookeeper起不起来) 2.上传至/usr/local/src 3.解压缩,并且移动到上级目录 4.进入主目录的config子目录, 5.修改server.properties配置文件 vim server.properties 内容如下: 6.保存并退出 7.主节点配置完毕,远程复制到另外两个节点 sc

Centos7安装zookeeper+kafka集群

Centos7安装zookeeper+kafka集群 1  Zookeeper和kafka简介 1)  ZooKeeper 是一个分布式的.分层级的文件系统,能促进客户端间的松耦合,并提供最终一致的,用于管理.协调Kafka代理,zookeeper集群中一台服务器作为Leader,其它作为Follower 2)  Apache Kafka 是分布式发布-订阅消息系统,kafka对消息保存时根据Topic进行归类,每个topic将被分成多个partition(区),每条消息在文件中的位置称为off

Ubuntu 1604 安装配置 kafka,并配置开机自启(systemctl)

安装 kafka 需要先安装 jdk.一.下载官网:http://kafka.apache.org/downloads.html 二.安装 安装参考:https://segmentfault.com/a/1190000012990954 1. 解压安装(我的安装目录/opt/kafka/) # tar -zvxf kafka_2.11-2.1.0.tgz 2.  修改配置 # vim /opt/kafka/kafka_2.11-2.1.0/config/server.properties 3.

【kafka】安装部署kafka集群(kafka版本:kafka_2.12-2.3.0)

2.1 下载kafka并安装kafka_2.12-2.3.0.tgz tar -zxvf kafka_2.12-2.3.0.tgz 2.2 配置kafka集群 在config/server.properties中修改参数: [[email protected] kafka_2.12-2.3.0]$ cd config [[email protected] config]$ gedit server.properties 参数1:添加host.name=hadoop01 #############

阿里云linux主机安装启动Jenkins

1.安装 网上查到的关于安装Jenkins的文章,都是需要先安装JDK和Tomcat,然后把war包丢进去运行.但是官方的介绍里面没有说要用Tomcat. 事实证明是不需要Tomcat的.而且Jenkins默认使用的也是8080端口,如果之前有启动默认配置的Tomcat,还需要先停掉. 我的服务器系统版本是CentOS 6.3,对应的说明是 Installing Jenkins on Red Hat Distributions 按照官方说明依次输入如下命令 #wget -O /etc/yum.r

判断App是否第一次安装启动

流行的解决方案是在大多数地方是用[NSUserDefaults standardUserDefaults的一个关键,如果它不存在,这意味着这是应用程序启动,否则,它不是第一次.然后,它说设置成后者在该方法的关键:“applicationWillTerminate:(UIApplication*)application”.这一解决方案非常好,直到我们得到的iOS 4.0.在iOS 4.0 +这种方法很少被称为(只适用于内存问题)在苹果的UIApplicationDelegate文档中所述....

HSQLDB源码学习——数据库安装启动及JDBC连接

HSQLDB 是一个轻量级的纯Java开发的开放源代码的关系数据库系统.因为HSQLDB的轻量(占用空间小),使用简单,支持内存运行方式等特点,HSQLDB被广泛用于开发环境和某些中小型系统中. 在http://sourceforge.net/projects/hsqldb/files/下载了HSQLDB 1.8.0版本.把下载的zip文件解压缩至任意目录例如c:\hsqldb1.8便完成安装. hsqldb有四种运行模式: 一.内存(Memory-Only)模式:所有数据都在内存里操作.应用程