diff --git a/rdkafka/RdKafka.php b/rdkafka/RdKafka.php index 89405e9a6..4817c6826 100755 --- a/rdkafka/RdKafka.php +++ b/rdkafka/RdKafka.php @@ -36,7 +36,7 @@ public function getOutQLen() {} * * @return Topic */ - public function newTopic($topic_name, ?TopicConf $topic_conf = null) {} + public function newTopic($topic_name, $topic_conf = null) {} /** * @param int $timeout_ms @@ -58,7 +58,7 @@ public function setLogLevel($level) {} * * @return TopicPartition[] */ - public function offsetsForTimes(array $topic_partitions, int $timeout_ms) {} + public function offsetsForTimes($topic_partitions, $timeout_ms) {} /** * @param string $topic @@ -69,21 +69,21 @@ public function offsetsForTimes(array $topic_partitions, int $timeout_ms) {} * * @return void */ - public function queryWatermarkOffsets(string $topic, int $partition = 0, int &$low = 0, int &$high = 0, int $timeout_ms = 0) {} + public function queryWatermarkOffsets($topic, $partition = 0, &$low = 0, &$high = 0, $timeout_ms = 0) {} /** * @param int $purge_flags * * @return int */ - public function purge(int $purge_flags) {} + public function purge($purge_flags) {} /** * @param int $timeout_ms * * @return int */ - public function flush(int $timeout_ms) {} + public function flush($timeout_ms) {} public function metadata($all_topics, $only_topic = false, $timeout_ms = 0) {} diff --git a/rdkafka/RdKafka/Conf.php b/rdkafka/RdKafka/Conf.php index 2f4ecc3ba..0496a9f30 100755 --- a/rdkafka/RdKafka/Conf.php +++ b/rdkafka/RdKafka/Conf.php @@ -27,54 +27,54 @@ public function set($name, $value) {} * * @return void */ - public function setDefaultTopicConf(TopicConf $topic_conf) {} + public function setDefaultTopicConf($topic_conf) {} /** * @param callable $callback * * @return void */ - public function setDrMsgCb(callable $callback) {} + public function setDrMsgCb($callback) {} /** * @param callable $callback * * @return void */ - public function setErrorCb(callable $callback) {} + public function setErrorCb($callback) {} /** * @param callable $callback * * @return void */ - public function setRebalanceCb(callable $callback) {} + public function setRebalanceCb($callback) {} /** * @param callable $callback * * @return void */ - public function setStatsCb(callable $callback) {} + public function setStatsCb($callback) {} /** * @param callable $callback * * @return void */ - public function setOffsetCommitCb(callable $callback) {} + public function setOffsetCommitCb($callback) {} /** * @param callable $callback * * @return void */ - public function setConsumeCb(callable $callback) {} + public function setConsumeCb($callback) {} /** * @param callable $callback * * @return void */ - public function setLogCb(callable $callback) {} + public function setLogCb($callback) {} } diff --git a/rdkafka/RdKafka/Consumer.php b/rdkafka/RdKafka/Consumer.php index ff9a32f55..f7e5492ca 100755 --- a/rdkafka/RdKafka/Consumer.php +++ b/rdkafka/RdKafka/Consumer.php @@ -7,7 +7,7 @@ class Consumer extends \RdKafka /** * @param null|Conf $conf */ - public function __construct(?Conf $conf = null) {} + public function __construct($conf = null) {} /** * @param string $topic_name diff --git a/rdkafka/RdKafka/ConsumerTopic.php b/rdkafka/RdKafka/ConsumerTopic.php index a7cc60ff1..fd9f71c10 100755 --- a/rdkafka/RdKafka/ConsumerTopic.php +++ b/rdkafka/RdKafka/ConsumerTopic.php @@ -21,7 +21,7 @@ public function consume($partition, $timeout_ms) {} * * @return void */ - public function consumeQueueStart($partition, $offset, Queue $queue) {} + public function consumeQueueStart($partition, $offset, $queue) {} /** * @param int $partition diff --git a/rdkafka/RdKafka/KafkaConsumer.php b/rdkafka/RdKafka/KafkaConsumer.php index e53ec647f..f982cdd3b 100755 --- a/rdkafka/RdKafka/KafkaConsumer.php +++ b/rdkafka/RdKafka/KafkaConsumer.php @@ -7,7 +7,7 @@ class KafkaConsumer /** * @param Conf $conf */ - public function __construct(Conf $conf) {} + public function __construct($conf) {} /** * @param TopicPartition[] $topic_partitions @@ -83,7 +83,7 @@ public function unsubscribe() {} * * @return array */ - public function getCommittedOffsets(array $topic_partitions, int $timeout_ms) {} + public function getCommittedOffsets($topic_partitions, $timeout_ms) {} /** * @param TopicPartition[] $topic_partitions @@ -91,7 +91,7 @@ public function getCommittedOffsets(array $topic_partitions, int $timeout_ms) {} * * @return TopicPartition[] */ - public function offsetsForTimes(array $topic_partitions, int $timeout_ms) {} + public function offsetsForTimes($topic_partitions, $timeout_ms) {} /** * @param string $topic @@ -102,12 +102,12 @@ public function offsetsForTimes(array $topic_partitions, int $timeout_ms) {} * * @return void */ - public function queryWatermarkOffsets(string $topic, int $partition = 0, int &$low = 0, int &$high = 0, int $timeout_ms = 0) {} + public function queryWatermarkOffsets($topic, $partition = 0, &$low = 0, &$high = 0, $timeout_ms = 0) {} /** * @param TopicPartition[] $topic_partitions */ - public function getOffsetPositions(array $topic_partitions) {} + public function getOffsetPositions($topic_partitions) {} /** * @param string $topic_name @@ -115,7 +115,7 @@ public function getOffsetPositions(array $topic_partitions) {} * * @return Topic */ - public function newTopic($topic_name, ?TopicConf $topic_conf = null) {} + public function newTopic($topic_name, $topic_conf = null) {} /** * @return void diff --git a/rdkafka/RdKafka/Producer.php b/rdkafka/RdKafka/Producer.php index 66e86f4e4..f08a15c1e 100755 --- a/rdkafka/RdKafka/Producer.php +++ b/rdkafka/RdKafka/Producer.php @@ -7,7 +7,7 @@ class Producer extends \RdKafka /** * @param null|Conf $conf */ - public function __construct(Conf $conf = null) {} + public function __construct($conf = null) {} /** * @param string $topic_name @@ -22,7 +22,7 @@ public function newTopic($topic_name, ?TopicConf $topic_conf = null) {} * * @return void */ - public function initTransactions(int $timeout_ms) {} + public function initTransactions($timeout_ms) {} /** * @return void @@ -34,12 +34,12 @@ public function beginTransaction() {} * * @return void */ - public function commitTransaction(int $timeout_ms) {} + public function commitTransaction($timeout_ms) {} /** * @param int $timeout_ms * * @return void */ - public function abortTransaction(int $timeout_ms) {} + public function abortTransaction($timeout_ms) {} }