Skip to content

Commit 299169e

Browse files
authored
Update kafka-consumer.php
1 parent b018c84 commit 299169e

File tree

1 file changed

+1
-42
lines changed

1 file changed

+1
-42
lines changed

config/kafka-consumer.php

Lines changed: 1 addition & 42 deletions
Original file line numberDiff line numberDiff line change
@@ -3,48 +3,7 @@
33
return [
44
'global_middleware' => [],
55

6-
'processors' => [
7-
[
8-
/*
9-
| Optional, defaults to `null`.
10-
| Here you may specify which topic should be handled by this processor.
11-
| Processor handles all topics by default.
12-
*/
13-
'topic' => 'stage.crm.fact.registrations.1',
14-
15-
/*
16-
| Optional, defaults to `null`.
17-
| Here you may specify which ensi/laravel-phprdkafka consumer should be handled by this processor.
18-
| Processor handles all consumers by default.
19-
*/
20-
'consumer' => 'default',
21-
22-
/*
23-
| Optional, defaults to `action`.
24-
| Here you may specify processor's type. Defaults to `action`
25-
| Supported types:
26-
| - `action` - a simple class with execute method;
27-
| - `job` - Laravel Queue Job. It will be dispatched using `dispatch` or `dispatchSync` method;
28-
*/
29-
'type' => 'action',
30-
31-
/*
32-
| Required.
33-
| Fully qualified class name of a processor class.
34-
*/
35-
'class' => \App\Domain\Communication\Actions\SendConfirmationEmailAction::class,
36-
37-
/*
38-
| Optional, defaults to `false`.
39-
| Proxy messages to Laravel's queue.
40-
| Supported values:
41-
| - `false` - do not stream message. Execute processor in syncronous mode;
42-
| - `true` - stream message to Laravel's default queue;
43-
| - `<your-favorite-queue-name-as-string>` - stream message to this queue;
44-
*/
45-
'queue' => false,
46-
],
47-
],
6+
'processors' => [],
487

498
'consumer_options' => [
509
/** options for consumer with name `default` */

0 commit comments

Comments
 (0)