linux下部署kafka

由于项目中要用到kafka，先在自己的虚拟机上部署试一下

1. 下载压缩包

https://www.apache.org/dyn/closer.cgi?path=/kafka/2.3.0/kafka_2.12-2.3.0.tgz

2. kafka运行依赖zookeeper，如未安装，可参照

https://www.cnblogs.com/pageBlog/p/11379211.html

3. 将压缩包上传到服务器

4. 解压：tar -xzf kafka_2.12-2.3.0.tgz

5. 进入kafka目录：cd kafka_2.12-2.3.0/

6. 启动：bin/kafka-server-start.sh config/server.properties

7. 创建话题"test"：

bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

　　列出话题列表，可以查看创建的话题：bin/kafka-topics.sh --list --bootstrap-server localhost:9092

8. 发送信息：bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

9. 启动消费者：bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning，可以看到收到了刚才生产者发送的消息

参考文档：

http://kafka.apache.org/quickstart

原文地址：https://www.cnblogs.com/pageBlog/p/11379364.html

时间： 2024-09-29 05:27:48

linux下部署kafka的相关文章

Linux下部署Kafka分布式集群，安装与测试

注意:部署Kafka之前先部署环境JAVA.Zookeeper 准备三台CentOS_6.5_x64服务器,分别是:IP: 192.168.0.249 dbTest249 Kafka IP: 192.168.0.250 Other250 Kafka IP: 192.168.0.251 webTest251 Kafka 一.安装Kafka # tar zxvf kafka_2.9.1-0.8.2.2.tgz -C /usr/local/ # cd /usr/local/kafka_2.9.1-0.

在Linux下部署kettle的Job

关于如何用kettle创建job以及如何部署kettle到linux上,我就不细说了,大家应该都会,下面重点说一下,如何让job执行起来先将创建好的脚本上传到kettle指定目录下面,创建调用job执行的脚本文件, export JAVA_HOME=/usr/java/jre1.6.0_23 export PATH=$JAVA_HOME/bin:$PATH export CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar /opt

windows 下部署kafka 日记转

windows 下部署kafka 日记转一.下载去apache 的官网(http://kafka.apache.org/downloads.html)下载最新的二进制版的压缩包.目前的最新版本是kafka_2.11-0.8.2.1.tgz.二.解压直接解压到D 盘根目录下.三.修改配置文件注意版本不同,可能配置文件不同.请参照实际情况修改.1．修改log4j.properties 文件中的“kafka.logs.dir=logs ”为“kafka.logs.dir=/tmp/logs”.2．修

Linux下部署docker记录（1）-Volume使用

之前部署了Linux下部署docker记录(0)-基础环境安装,接下来看看Docker Volume的使用. Docker volume使用1)一个数据卷是一个特别指定的目录,该目录利用容器的UFS文件系统可以为容器提供一些稳定的特性或者数据共享.数据卷可以在多个容器之间共享.2)创建数据卷,只要在docker run命令后面跟上-v参数即可创建一个数据卷,当然你也可以跟多个-v参数来创建多个数据卷,当创建好带有数据卷的容器后,你就可以在其他容器中通过--volumes-froms参数来挂载该数

linux下部署项目问题

1. 今天linux下部署thinkphp项目,数据库用的mysql. 页面其他都是正常的,但是从数据库中取出的数据都是乱码.最后查了资料解决方案: 在ThinkPHP里面 Library\Think\Db\Driver.class.php 103行后加上 $this->linkID[$linkNum] ->query("set names utf8");

Linux下部署多个Tomcat（完整）

Linux下部署多个Tomcat 1.环境:1.1.Centos 5.01.2.apache-tomcat-6.0.18 2.需要解决一下几个问题2.1.不同的tomcat启动和关闭监听不同的端口2.2.不同的tomcat的启动文件startup.sh 中要指定各自的CATALINA_HOME和CATALINA_BASE这两个环境变量. 3.解决步骤: 3.1.修改/etc目录下的profile文件,添加一组java环境变量,和两组CATALINA环境变量:修改后的profile文件示例如下:J

【初级篇】Linux下部署DNS域名解析服务

Linux下部署DNS域名解析服务 1. 实验需求: 1) 使用RPM包安装bind服务 2) 实现配置正向解析域名,反向解析IP地址. 3)搭建从服务器,实现配置和主服务器实时同步,相互提供冗余备份. 2. 实验环境: Linux服务器系统版本:Red Hat Enterprise Linux 6.5(主) IP:192.168.10.20 Linux服务器系统版本:Red Hat Enterprise Linux 6.5(从) IP:192

Linux下部署tomcat

在Linux系统下,重启Tomcat使用命令操作的! 首先,进入Tomcat下的bin目录 cd /usr/local/tomcat/bin 使用Tomcat关闭命令 ./shutdown.sh 查看Tomcat是否以关闭 ps -ef|grep java 如果显示以下相似信息,说明Tomcat还没有关闭 root 7010 1 0 Apr19 ? 00:30:13 /usr/local/java/bin/java -Djava.util.logging.config.file=/usr/loc

linux下部署jenkins

今天做作业连了一天的mysql. 最后我痛定思痛,决定从0开始学习jsp,省的又面临不会的局面. 忙活了一晚上,终于把数据库连接上了,不过,好伤心啊,我连个数据库都这么墨迹... <%@ page language="java" import="java.util.*" pageEncoding="utf-8"%> <%@page import="data.database"%> <%@page