File tree 8 files changed +114
-1
lines changed
8 files changed +114
-1
lines changed Original file line number Diff line number Diff line change @@ -10,4 +10,5 @@ draft: false
10
10
[ ![ License: BSD-3] ( https://img.shields.io/badge/License-BSD--3-green.svg )] ( https://github.com/php-kafka/php-kafka/blob/main/LICENSE )
11
11
12
12
This extension provides ways to interact with Apache Kafka.
13
- It uses [ librdkafka] ( https://github.com/edenhill/librdkafka ) for binding and was inspired by [ php-rdkafka] ( https://github.com/arnaud-lb/php-rdkafka ) .
13
+ You can find some examples for producer and consumer [ here] ( https://github.com/php-kafka/php-kafka-examples/tree/main/src/ext-php-kafka )
14
+ This extension uses [ librdkafka] ( https://github.com/edenhill/librdkafka ) for binding and was inspired by [ php-rdkafka] ( https://github.com/arnaud-lb/php-rdkafka ) .
Original file line number Diff line number Diff line change
1
+ ---
2
+ title : " __construct"
3
+ date : 2020-12-27T22:09:37+01:00
4
+ draft : false
5
+ ---
6
+ ## Description
7
+ ``` php
8
+ public function __construct(Configuration $configuration) {}
9
+ ```
10
+ Get a producer instance
11
+ ## Example
12
+ ``` php
13
+ $conf = Kafka\Configuration();
14
+ $conf->set('metadata.broker.list', 'kafka:9092');
15
+ $producer = new Kafka\Producer($conf);
16
+ ```
Original file line number Diff line number Diff line change
1
+ ---
2
+ title : " abortTransaction"
3
+ date : 2020-12-27T22:09:37+01:00
4
+ draft : false
5
+ ---
6
+ ## Description
7
+ ``` php
8
+ public function abortTransaction(int $timeoutMs): void {}
9
+ ```
10
+ Get a producer instance
11
+ ## Example
12
+ ``` php
13
+ $conf = Kafka\Configuration();
14
+ $conf->set('metadata.broker.list', 'kafka:9092');
15
+ $producer = new Kafka\Producer($conf);
16
+ ```
Original file line number Diff line number Diff line change
1
+ ---
2
+ title : " beginTransaction"
3
+ date : 2020-12-27T22:09:37+01:00
4
+ draft : false
5
+ ---
6
+ ## Description
7
+ ``` php
8
+ public function beginTransaction(): void {}
9
+ ```
10
+ Get a producer instance
11
+ ## Example
12
+ ``` php
13
+ $conf = Kafka\Configuration();
14
+ $conf->set('metadata.broker.list', 'kafka:9092');
15
+ $producer = new Kafka\Producer($conf);
16
+ ```
Original file line number Diff line number Diff line change
1
+ ---
2
+ title : " commitTransaction"
3
+ date : 2020-12-27T22:09:37+01:00
4
+ draft : false
5
+ ---
6
+ ## Description
7
+ ``` php
8
+ public function commitTransaction(int $timeoutMs): void {}
9
+ ```
10
+ Get a producer instance
11
+ ## Example
12
+ ``` php
13
+ $conf = Kafka\Configuration();
14
+ $conf->set('metadata.broker.list', 'kafka:9092');
15
+ $producer = new Kafka\Producer($conf);
16
+ ```
Original file line number Diff line number Diff line change
1
+ ---
2
+ title : " flush"
3
+ date : 2020-12-27T22:09:37+01:00
4
+ draft : false
5
+ ---
6
+ ## Description
7
+ ``` php
8
+ public function flush(int $timeoutMs): int {}
9
+ ```
10
+ Get a producer instance
11
+ ## Example
12
+ ``` php
13
+ $conf = Kafka\Configuration();
14
+ $conf->set('metadata.broker.list', 'kafka:9092');
15
+ $producer = new Kafka\Producer($conf);
16
+ ```
Original file line number Diff line number Diff line change
1
+ ---
2
+ title : " initTransactions"
3
+ date : 2020-12-27T22:09:37+01:00
4
+ draft : false
5
+ ---
6
+ ## Description
7
+ ``` php
8
+ public function initTransactions(int $timeoutMs): void {}
9
+ ```
10
+ Get a producer instance
11
+ ## Example
12
+ ``` php
13
+ $conf = Kafka\Configuration();
14
+ $conf->set('metadata.broker.list', 'kafka:9092');
15
+ $producer = new Kafka\Producer($conf);
16
+ ```
Original file line number Diff line number Diff line change
1
+ ---
2
+ title : " purge"
3
+ date : 2020-12-27T22:09:37+01:00
4
+ draft : false
5
+ ---
6
+ ## Description
7
+ ``` php
8
+ public function purge(int $purgeFlags): int {}
9
+ ```
10
+ Get a producer instance
11
+ ## Example
12
+ ``` php
13
+ $conf = Kafka\Configuration();
14
+ $conf->set('metadata.broker.list', 'kafka:9092');
15
+ $producer = new Kafka\Producer($conf);
16
+ ```
You can’t perform that action at this time.
0 commit comments