Skip to content

Commit 2bb7f9c

Browse files
authored
feat(MPM-553): add missing docblock (#74)
1 parent 6ab6b06 commit 2bb7f9c

File tree

3 files changed

+9
-6
lines changed

3 files changed

+9
-6
lines changed

.circleci/config.yml

+1-1
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@ version: 2.1
22

33
orbs:
44
ci-caching: jobcloud/[email protected]
5-
ci-php: jobcloud/ci-php@2.4
5+
ci-php: jobcloud/ci-php@2.5
66

77
workflows:
88
test-php-kafka-lib:

docker/dev/php/Dockerfile

+2-5
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
FROM php:7.4-cli-alpine3.13
1+
FROM php:7.4-cli-alpine3.16
22

33
ARG HOST_USER_ID
44
ARG HOST_USER
@@ -10,10 +10,7 @@ COPY files/php/ /phpIni
1010

1111
# SYS: Install required packages
1212
RUN apk --no-cache upgrade && \
13-
apk --no-cache add bash git sudo openssh autoconf gcc g++ make
14-
15-
RUN apk add librdkafka librdkafka-dev \
16-
--update-cache --repository http://dl-3.alpinelinux.org/alpine/edge/community
13+
apk --no-cache add bash git sudo openssh autoconf gcc g++ make librdkafka librdkafka-dev
1714

1815
# we need support for users with ID higher than 65k, so instead of using this:
1916
#RUN adduser -u $HOST_USER_ID -D -H $HOST_USER

src/Consumer/KafkaConsumerInterface.php

+6
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,9 @@
44

55
namespace Jobcloud\Kafka\Consumer;
66

7+
use Jobcloud\Kafka\Exception\KafkaConsumerConsumeException;
8+
use Jobcloud\Kafka\Exception\KafkaConsumerEndOfPartitionException;
9+
use Jobcloud\Kafka\Exception\KafkaConsumerTimeoutException;
710
use Jobcloud\Kafka\Message\KafkaConsumerMessageInterface;
811
use RdKafka\Metadata\Topic as RdKafkaMetadataTopic;
912
use RdKafka\TopicPartition as RdKafkaTopicPartition;
@@ -45,6 +48,9 @@ public function isSubscribed(): bool;
4548
* @param integer $timeoutMs
4649
* @param boolean $autoDecode
4750
* @return KafkaConsumerMessageInterface
51+
* @throws KafkaConsumerConsumeException
52+
* @throws KafkaConsumerEndOfPartitionException
53+
* @throws KafkaConsumerTimeoutException
4854
*/
4955
public function consume(int $timeoutMs = 10000, bool $autoDecode = true): KafkaConsumerMessageInterface;
5056

0 commit comments

Comments
 (0)