逍遥阁

kafka学习笔记

关键词: kafka

kafka学习笔记

### 安装

在`http://kafka.apache.org/downloads`这个下载页面选择二进制包，比如`kafka_2.12-1.1.0.tgz`

其中`2.12`是Scala的版本，`1.1.0`是kafka的版本，解压后就可以直接使用了

### 启动zookeeper

```
bin/zookeeper-server-start.sh config/zookeeper.properties
```

### 启动kafka

```
bin/kafka-server-start.sh config/server.properties
```

默认的配置只能本地访问，如果要让其他机器访问，需要修改配置文件里面的如下配置

```
listeners=PLAINTEXT://192.168.1.20:9092
```

ip地址不支持`0.0.0.0`这样的格式

### 创建一个主题test

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

### 列出主题

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

### 开启一个生产者

```
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
```

在终端输入一些信息后按回车就发送消息到主题了

### 开启一个消费者

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

### 查看版本信息

```
bin/kafka-broker-api-versions.sh --bootstrap-server localhost:9092
```

### php连接kafka

可以使用`https://github.com/weiboad/kafka-php`这个库，无需安装拓展

admin
2018-06-26 23:21:03
linux

文章分类

文章标签

文章归档

友情链接

kafka学习笔记