Kafka安装

痛定思痛。 2023-06-30 01:50 5阅读 0赞

在Kafka安装之前需要先安装jdk，zookeeper。

jdk的安装这里不详细介绍，推荐直接使用wget的方式下载openjdk，

下载了openjdk后，后续不需要配置，且其他（像以前的tomcat，zookeeper

和kafka都不需要特别的配置java的相关配置了！）

下面直接从zookeeper的下载开始：

# 1.从Apache的官网是下载，这里使用3.4.6版本，下载tar.gz版本。 #

而后使用：

tar -xvf zookeeper-3.4.6.tar.gz -C 目标地址

来解压。

接着修改配置文件：conf文件夹下的zoo.cfg。（也可以直接在Ubuntu中

直接点进去修改）

cat > /usr/local/zookeeper/conf/zoo.cfg << EOF 
    > tickTime=2000 
    > dataDir=/var/lib/zookeeper 
    > clientPort=2181 
    > EOF

## 开启zookeeper： ##

/usr/local/zookeeper/bin/zkServer.sh start 
    JMX enabled by default Using config: /usr/local/zookeeper/bin/../conf/zoo.cfg Starting zookeeper ... STARTED

关键点：bin/zkServer.sh start

可以使用如下的命令来检验是否安装成功！

# telnet localhost 2181 
    Trying ::1... 
    Connected to localhost. 
    Escape character is '^]'. 
    srvr 
    Zookeeper version: 3.4.6-1569965, built on 02/20/2014 09:09 GMT 
    Latency min/avg/max: 0/0/0 
    Received: 1 
    Sent: 0 
    Connections: 1 
    Outstanding: 0 
    Zxid: 0x0 
    Mode: standalone 
    Node count: 4 
    Connection closed by foreign host.

# 2.下面来安装Kafka #

# 去Apache官网上下载，下载tar.gz。 #

这里使用kafka的版本为：0.9.0.1

## 下载后，解压： ##

tar -xvf kafka_2.11-0.9.0.1.tar.gz -C 目标地址

## 我们来启动： ##

地址/bin/kafka-server-start.sh -daemon
    地址/kafka/config/server.properties

## 创建主题来验证： ##

# /usr/local/kafka/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test Created topic "test". 
    # /usr/local/kafka/bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic test Topic:test    PartitionCount:1    ReplicationFactor:1    Configs:    Topic: test    Partition: 0    Leader: 0    Replicas: 0    Isr: 0 #

## 往主题中发送消息： ##

# /usr/local/kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test 
    Test Message 1 
    Test Message 2 
    ^D 
    #

## 从主题中拉取消息： ##

# /usr/local/kafka/bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning 
    Test Message 1 
    Test Message 2 
    ^C 
    Consumed 2 messages 
    #

# 现在我们来总结命令： #

## 开启zookeeper： ##

/usr/local/zookeeper/bin/zkServer.sh start 
    JMX enabled by default Using config: /usr/local/zookeeper/bin/../conf/zoo.cfg Starting zookeeper ... STARTED

## 启动kafka： ##

地址/bin/kafka-server-start.sh -daemon
    地址/kafka/config/server.properties

## 从主题里面拉取数据： ##

# /usr/local/kafka/bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning