Log handler sends log events to a kafka server. More...

Inheritance diagram for MediaWiki\Logger\Monolog\KafkaHandler:

Collaboration diagram for MediaWiki\Logger\Monolog\KafkaHandler:

Public Member Functions
static array	__construct (Produce $produce, array $options, $level=Logger::DEBUG, $bubble=true)

	handleBatch (array $batch)

Static Public Member Functions
static	factory ($kafkaServers, array $options=[], $level=Logger::DEBUG, $bubble=true)
	Constructs the necessary support objects and returns a KafkaHandler instance. More...

Protected Member Functions
	addMessages ($channel, array $records)
	Adds records for a channel to the Kafka client internal queue. More...

	getRandomPartition ($topic)

	send ()
	Send any records in the kafka client internal queue. More...

	warning ($message, array $context=[])

	write (array $record)

Protected Attributes
array	$options
	Optional handler configuration. More...

array	$partitions = []
	Map from topic name to partition this request produces to. More...

Produce	$produce
	Sends requests to kafka. More...

Static Private Attributes
static array	$defaultOptions
	defaults for constructor options More...

Detailed Description

Log handler sends log events to a kafka server.

Constructor options array arguments:

alias: map from monolog channel to kafka topic name. When no alias exists the topic "monolog_$channel" will be used.
swallowExceptions: Swallow exceptions that occur while talking to kafka. Defaults to false.
logExceptions: Log exceptions talking to kafka here. Either null, the name of a channel to log to, or an object implementing FormatterInterface. Defaults to null.

Requires the nmred/kafka-php library, version >= 1.3.0

Author: Erik Bernhardson ebern.nosp@m.hard.nosp@m.son@w.nosp@m.ikim.nosp@m.edia..nosp@m.org

Definition at line 49 of file KafkaHandler.php.

Constructor & Destructor Documentation

static array MediaWiki\Logger\Monolog\KafkaHandler::__construct	(	Produce	$produce,
		array	$options,
			$level = `Logger::DEBUG`,
			$bubble = `true`
	)

Parameters

Produce	$produce	Kafka instance to produce through
array	$options	optional handler configuration
int	$level	The minimum logging level at which this handler will be triggered
bool	$bubble	Whether the messages that are handled can bubble up the stack or not

Definition at line 81 of file KafkaHandler.php.

MediaWiki\Logger\Monolog\KafkaHandler::addMessages	(		$channel,
		array	$records
	)

protected

Adds records for a channel to the Kafka client internal queue.

Parameters

string	$channel	Name of Monolog channel records belong to
array	$records	List of records to append

Definition at line 256 of file KafkaHandler.php.

static MediaWiki\Logger\Monolog\KafkaHandler::factory	(		$kafkaServers,
		array	$options = `[]`,
			$level = `Logger::DEBUG`,
			$bubble = `true`
	)

static

Constructs the necessary support objects and returns a KafkaHandler instance.

Parameters

	string[]	$kafkaServers
array	$options
int	$level	The minimum logging level at which this handle will be triggered
bool	$bubble	Whether the messages that are handled can bubble the stack or not