# kafka-docker

**Repository Path**: heroDtq/kafka-docker

## Basic Information

- **Project Name**: kafka-docker
- **Description**: kafka 服务docker化
- **Primary Language**: Docker
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 2
- **Created**: 2017-06-04
- **Last Updated**: 2020-12-19

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

这个项目主要以docker的形式跑起kafka。

## 先决条件

### 首先需要zookeeper
kafka集群需要借助服务注册，这里使用的zookeeper。

如果没有已经部署的zookeeper，项目有部署zookeeper的脚本（`start-zookeeper.sh`），可以选择机器部署。

```
./start-zookeeper.sh
```

### 非必须，可以用kafka-manager
kafka集群可以通过kafka-manager，web UI项目进行查看，同时管理集群信息。

这个不是先决条件，项目有`start-kafka-manager.sh`脚本，可以选择机器部署，但是将脚本中涉及zookeeper的地址根据实际部署机子进行调整。

```
./start-kafka-manager.sh
```

## 部署

项目提供脚本：`start-kafka.sh`

需要调整脚本的zookeeper地址，如果同一台机子部署多个kafka，则需要调整脚本中暴露的端口号，避免端口冲突。

```
# 执行
./start-kafka.sh
```

## create topic
如果有创建topic的需求，可以通过`createTopic.sh` 脚本完成，默认创建的topic会有6个partition，1个replication

```
# 例子，参数1是topic
./createTopic.sh test

# 或者可以指定zookeeper地址
./createTopic.sh test 112.74.76.100
```

## delete topic
如果有删除topic的需求，可以通过`deleteTopic.sh` 脚本完成

```
# 例子，参数1是topic
./deleteTopic.sh test

# 或者可以指定zookeeper地址
./deleteTopic.sh test 112.74.76.100
```