MediaWiki
1.30.0
|
Event relayer for Apache Kafka. More...
Public Member Functions | |
__construct (array $params) | |
Create Kafka producer. More... | |
Public Member Functions inherited from EventRelayer | |
notify ( $channel, $event) | |
notifyMulti ( $channel, $events) | |
setLogger (LoggerInterface $logger) | |
Protected Member Functions | |
doNotify ( $channel, array $events) | |
getKafkaProducer () | |
Get the producer object from kafka-php. More... | |
Protected Attributes | |
Config | $config |
Configuration. More... | |
Produce | $producer |
Kafka producer. More... | |
Protected Attributes inherited from EventRelayer | |
LoggerInterface | $logger |
Event relayer for Apache Kafka.
Configuring for WANCache: 'relayerConfig' => [ 'class' => 'EventRelayerKafka', 'KafkaEventHost' => 'localhost:9092' ],
Definition at line 9 of file EventRelayerKafka.php.
EventRelayerKafka::__construct | ( | array | $params | ) |
Create Kafka producer.
array | $params |
Reimplemented from EventRelayer.
Definition at line 29 of file EventRelayerKafka.php.
References $params.
|
protected |
string | $channel | |
array | $events | List of event data maps |
Reimplemented from EventRelayer.
Definition at line 50 of file EventRelayerKafka.php.
References $e, $producer, and getKafkaProducer().
|
protected |
Get the producer object from kafka-php.
Definition at line 42 of file EventRelayerKafka.php.
References $producer.
Referenced by doNotify().
|
protected |
Configuration.
Definition at line 15 of file EventRelayerKafka.php.
|
protected |
Kafka producer.
Definition at line 22 of file EventRelayerKafka.php.
Referenced by doNotify(), and getKafkaProducer().