cs

arrilot · arrilot · commit 8a9588fc688a · 2021-10-21T23:45:51.000+03:00
diff --git a/src/HighLevelConsumer.php b/src/HighLevelConsumer.php
@@ -55,9 +55,7 @@ public function listen(string $processorClassName, string $processorType, string
                     throw new KafkaConsumerException('Kafka error: ' . $message->errstr());
             }
 
-            if ($this->shouldBeStopped(
-                $startTime, $eventsProcessed
-            )) {
+            if ($this->shouldBeStopped($startTime, $eventsProcessed)) {
                 break;
             }
         }

Original file line number	Diff line number	Diff line change
`@@ -55,9 +55,7 @@ public function listen(string $processorClassName, string $processorType, string`
`55`	`55`	`throw new KafkaConsumerException('Kafka error: ' . $message->errstr());`
`56`	`56`	`}`
`57`	`57`
`58`		`- if ($this->shouldBeStopped(`
`59`		`- $startTime, $eventsProcessed`
`60`		`- )) {`
	`58`	`+ if ($this->shouldBeStopped($startTime, $eventsProcessed)) {`
`61`	`59`	`break;`
`62`	`60`	`}`
`63`	`61`	`}`