启动Kafka

启动zookeeper

使用命令查看zookeeper是否启动成功：

启动kafka Brokerr

使用命令查看kafka Broker是否启动更成功

在kafka中创建topic ‘test‘

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

列出所有的topic

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

产生数据

原文地址：https://www.cnblogs.com/wl2017/p/10373865.html

时间： 2024-10-29 19:41:59

启动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

全网最详细的启动Kafka服务时出现kafka.common.InconsistentBrokerIdException: Configured brokerId 3 doesn't match stored brokerId 1 in meta.properties错误的解决办法（图文详解）

不多说,直接上干货! 问题详情 执行bin/kafka-server-start.sh config/server.properties 时, [[email protected] kafka_2.11-0.9.0.0]$ bin/kafka-server-start.sh config/server.properties [2018-06-17 16:05:38,983] INFO KafkaConfig values: request.timeout.ms = 30000 log.roll.

安装启动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 #查看进程,带上全

首次启动Kafka报Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00000000c0000000, 1073741824, 0) failed; error='Cannot allocate memory' (errno=12)

首次启动Kafka报错如下: 原因:内存不足,查看启动配置 调小一些: 首次启动Kafka报Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00000000c0000000, 1073741824, 0) failed; error='Cannot allocate memory' (errno=12) 原文地址:https://www.cnblogs.com/zjfjava/p/10325523.html

启动kafka报错

执行启动kafka服务的命令时报错:nohup bin/kafka-server-start.sh config/server.properties 2>&1 & [2019-07-28 12:58:44,760] ERROR [ReplicaManager broker=1] Error while making broker the follower for partition Topic: __consumer_offsets; Partition: 41; Leader: N

【kafka】一键启动kafka脚本

3.1 创建文件cd bin 跳转到bin文件夹里touch  start-kafka-cluster.sh --新建一键启动文件touch  stop-kafka-cluster.sh --新建一键停止文件 3.2 编写startstart-kafka-cluster.sh内容:#!/bin/bashbrokers="hadoop01 hadoop02 hadoop03"KAFKA_HOME="/home/hadoop/kafka_2.12-2.3.0"KAFKA

启动kafka出现找不到或无法加载主类

首先确认下环境变量配置是否成功. 如果配置成功<javac,javah>都没有问题,那就有可能是你安装了两个版本的jdk导致的,都卸载了,然后换一个目录按照一个jdk 在配置环境变量试下!

kafka启动及查看topic命令【已用过的，待更新】

以下均为开发测试环境下: 启动Zookeeperbin/zookeeper-server-start.sh config/zookeeper.properties &启动kafkabin/kafka-server-start.sh config/server.properties创建topicbin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic r

mac 启动本地kafka

打开终端执行下列命令 1.zkserver start    ----启动zk 2.启动kafka 2.1 cd /usr/local/Cellar/kafka/  ---到kafka安装目录 2.2 ls      ----查看kafka版本 比如我到是 0.11.0.1 2.3 cd 0.11.0.1 2.4 cd bin 2.5 ./kafka-server-start /usr/local/etc/kafka/server.properties  ---执行kafka启动脚本