# kafka_server

**Repository Path**: longchun4835/kafka_server

## Basic Information

- **Project Name**: kafka_server
- **Description**: kafka环境一键安装
- **Primary Language**: Unknown
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2021-11-16
- **Last Updated**: 2021-12-15

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

+ 安装:
  ```
    ./install_kafka.sh
  ```

  查看是否启动成功
 ```
   netstat -ntlp
 ```
 ```
   tcp6       0      0 :::9092                 :::*                    LISTEN      73563/java
   tcp6       0      0 :::2181                 :::*                    LISTEN      72717/java

 ```
  如上面所示，9092端口以及2181端口启动了说明启动成功；
  
  
  2181是zookeeper监听端口，9092是kafka监听端口；
  如果9092端口没启动成功，或者2181端口没启动成功，可以手动启动，启动顺序为先启动zookeeper,启动成功后才能启动kafka;
+ 启动zookeeper:
  到zookeeper目录下执行如下命令
 ```
   bin/zkServer.sh start
 ```
+ 启动kafka:
  到kafka目录下执行如下命令
 ```
   bin/kafka-server-start.sh -daemon config/server.properties
 ```


+ 使用:
  在kafka目录下

  创建topic
 ```
   bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test
 ```
 
  列出topic
 ```
   bin/kafka-topics.sh --list --bootstrap-server localhost:9092
 ```

  生产者
 ```
   bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic test
 ```

  消费者
 ```
   bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
 ```


+ 参考文档
 ```
   https://www.w3cschool.cn/apache_kafka/apache_kafka_installation_steps.html
 ```