kafka: Implement ack handling
authorErik Bernhardson <ebernhardson@wikimedia.org>
Fri, 3 Jun 2016 00:44:43 +0000 (17:44 -0700)
committerErik Bernhardson <ebernhardson@wikimedia.org>
Thu, 23 Jun 2016 15:12:29 +0000 (08:12 -0700)
commite761c8847ac7b5e192a038df5a2d06abeeb8e9a5
tree40ee52788a29d2ebcd6d3aefff6b9e6496962501
parent8d58a592f7e0561440f84b5f13c03bb2efc797c9
kafka: Implement ack handling

By default the kafka implementation we use doesn't require any kind of
acknowledgment, it just throws messages into the wind and lets them sit
where they may. Implement an option for KafkaHandler to specify the
number of acks (number of replicas that must record the message) and
some error handling to throw exceptions as necessary when there is a
problem.

Bug: T135159
Change-Id: I859dc791072db407f908b2f36be0d6704f1a6256
includes/debug/logger/monolog/KafkaHandler.php
tests/phpunit/includes/debug/logger/monolog/KafkaHandlerTest.php