Skip to content
This repository was archived by the owner on Jun 10, 2022. It is now read-only.

Commit c593d87

Browse files
committed
fixed cs
1 parent 731b9db commit c593d87

File tree

3 files changed

+4
-7
lines changed

3 files changed

+4
-7
lines changed

src/Broker.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -173,7 +173,7 @@ public function getConnect(string $key, string $type, bool $modeSync = false): ?
173173
$port = null;
174174

175175
if (isset($this->brokers[$key])) {
176-
$hostname = $this->brokers[$key];
176+
$hostname = $this->brokers[$key];
177177

178178
[$host, $port] = explode(':', $hostname);
179179
}

src/Consumer/Process.php

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -802,8 +802,8 @@ protected function stateConvert(int $errorCode, ?array $context = null): bool
802802
}
803803

804804
if ($errorCode === Protocol::OFFSET_OUT_OF_RANGE) {
805-
$resetOffset = $this->getConfig()->getOffsetReset();
806-
$offsets = $resetOffset === 'latest' ? $assign->getLastOffsets() : $assign->getOffsets();
805+
$resetOffset = $this->getConfig()->getOffsetReset();
806+
$offsets = $resetOffset === 'latest' ? $assign->getLastOffsets() : $assign->getOffsets();
807807

808808
[$topic, $partId] = $context;
809809

src/SingletonTrait.php

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -15,10 +15,7 @@ trait SingletonTrait
1515
*/
1616
protected static $instance;
1717

18-
/**
19-
* @return object
20-
*/
21-
public static function getInstance()
18+
public static function getInstance(): object
2219
{
2320
if (self::$instance === null) {
2421
static::$instance = new static();

0 commit comments

Comments
 (0)