PHPackages                             ryan1068/yii2-kafka - PHPackages - PHPackages  [Skip to content](#main-content)[PHPackages](/)[Directory](/)[Categories](/categories)[Trending](/trending)[Leaderboard](/leaderboard)[Changelog](/changelog)[Analyze](/analyze)[Collections](/collections)[Log in](/login)[Sign up](/register)

1. [Directory](/)
2. /
3. [Utility & Helpers](/categories/utility)
4. /
5. ryan1068/yii2-kafka

ActiveYii2-extension[Utility & Helpers](/categories/utility)

ryan1068/yii2-kafka
===================

Yii2 kafka extension

18[1 PRs](https://github.com/ryan1068/yii2-kafka/pulls)PHP

Since Apr 22Pushed 5y ago1 watchersCompare

[ Source](https://github.com/ryan1068/yii2-kafka)[ Packagist](https://packagist.org/packages/ryan1068/yii2-kafka)[ RSS](/packages/ryan1068-yii2-kafka/feed)WikiDiscussions master Synced 2d ago

READMEChangelogDependenciesVersions (3)Used By (0)

yii2-kafka
==========

[](#yii2-kafka)

### 通过docker安装kafka，zookeeper服务

[](#通过docker安装kafkazookeeper服务)

#### docker-compose配置：

[](#docker-compose配置)

```
### ZooKeeper #########################################
    zookeeper:
      build: ./zookeeper
      volumes:
        - ${DATA_PATH_HOST}/zookeeper/data:/data
        - ${DATA_PATH_HOST}/zookeeper/datalog:/datalog
      ports:
        - "${ZOOKEEPER_PORT}:2181"
      networks:
        - backend

### kafka ####################################################
    kafka:
      image: wurstmeister/kafka
      ports:
        - "9092:9092"
      environment:
        KAFKA_BROKER_ID: 1
        KAFKA_ADVERTISED_HOST_NAME: 192.168.0.1
        KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://192.168.0.1:9092
        KAFKA_MESSAGE_MAX_BYTES: 2000000
        KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
      volumes:
        - ./kafka:/kafka
        - /var/run/docker.sock:/var/run/docker.sock
      networks:
        - backend

### kafka-manager ####################################################
    kafka-manager:
      image: sheepkiller/kafka-manager
      ports:
        - 9020:9000
      environment:
        ZK_HOSTS: zookeeper:2181
      networks:
        - backend
```

#### Yii2配置：

[](#yii2配置)

Config:

```
'components' => [
    'kafka' => [
        'class' => yii\kafka\Producer::class,
        'as log' => yii\kafka\KafkaBehavior::class,
    ],
]
```

Params:

```
'params' => [
    'kafka' => [
        'broker_list' => '192.168.0.1:9092,192.168.0.2:9092,192.168.0.3:9092',
        'topic' => [
            'auto.commit.interval.ms' => 100,
            'offset.store.method' => 'broker',
            'auto.offset.reset' => 'earliest',
        ],
    ],
]
```

#### 使用示例:

[](#使用示例)

```
// 消费者使用示例