as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

改名

Browse Source
This commit is contained in:
Mr·x
2021-03-02 15:06:37 +08:00
parent d7bf22d5fe
commit b330e95d22
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Kafka/Kafka.php
+4 -2
View File
@@ -46,12 +46,13 @@ class Kafka extends \Snowflake\Process\Process
/** /**
* @param array $kafkaServer * @param array $kafkaServer
* @throws ComponentException
*/ */
private function waite(array $kafkaServer) private function waite(array $kafkaServer)
{ {
try { try {
$prefix = ucfirst(rtrim(Snowflake::app()->id, ':')); $prefix = rtrim(Snowflake::app()->id, ':');
swoole_set_process_name($prefix . ': Kafka Consumer ' . $kafkaServer['topic']); swoole_set_process_name($prefix . ' Kafka Consumer ' . $kafkaServer['topic']);
[$config, $topic, $conf] = $this->kafkaConfig($kafkaServer); [$config, $topic, $conf] = $this->kafkaConfig($kafkaServer);
if (empty($config) && empty($topic) && empty($conf)) { if (empty($config) && empty($topic) && empty($conf)) {
@@ -73,6 +74,7 @@ class Kafka extends \Snowflake\Process\Process
/** /**
* @param ConsumerTopic $topic * @param ConsumerTopic $topic
* @param $interval * @param $interval
* @throws ComponentException
*/ */
private function resolve(ConsumerTopic $topic, $interval) private function resolve(ConsumerTopic $topic, $interval)
{ {