不再使用BaseInjectValue作为注解属性值

src/Components/kafka/example/Kafka/Test/TestConsumer.php → src/Components/kafka/example/Kafka/Test/TestConsumerSwoole.php

@@ -8,15 +8,14 @@
 use Imi\Kafka\Annotation\Consumer;
 use Imi\Kafka\Base\BaseConsumer;
 use Imi\Redis\Redis;
-use KafkaApp\Annotation\GetGroupId;
 use longlang\phpkafka\Consumer\ConsumeMessage;
 
 /**
- * @Bean("TestConsumer")
+ * @Bean("TestConsumerSwoole")
  *
- * @Consumer(topic="queue-imi-1", groupId=@GetGroupId)
+ * @Consumer(topic="queue-imi-1", groupId="test-consumer-swoole")
  */
-class TestConsumer extends BaseConsumer
+class TestConsumerSwoole extends BaseConsumer
 {
     /**
      * 消费任务

src/Components/kafka/example/Kafka/Test/TestConsumerWorkerman.php

@@ -0,0 +1,29 @@
+<?php
+
+declare(strict_types=1);
+
+namespace KafkaApp\Kafka\Test;
+
+use Imi\Bean\Annotation\Bean;
+use Imi\Kafka\Annotation\Consumer;
+use Imi\Kafka\Base\BaseConsumer;
+use Imi\Redis\Redis;
+use longlang\phpkafka\Consumer\ConsumeMessage;
+
+/**
+ * @Bean("TestConsumerWorkerman")
+ *
+ * @Consumer(topic="queue-imi-1", groupId="test-consumer-workerman")
+ */
+class TestConsumerWorkerman extends BaseConsumer
+{
+    /**
+     * 消费任务
+     */
+    protected function consume(ConsumeMessage $message): void
+    {
+        $data = json_decode($message->getValue(), true);
+        var_dump(__CLASS__, $message->getValue());
+        Redis::set('imi-kafka:consume:1:' . $data['memberId'], $message->getValue());
+    }
+}

src/Components/kafka/example/Process/SwooleTestProcess.php

@@ -19,9 +19,9 @@
 class SwooleTestProcess extends BaseProcess
 {
     /**
-     * @Inject("TestConsumer")
+     * @Inject("TestConsumerSwoole")
      *
-     * @var \KafkaApp\Kafka\Test\TestConsumer
+     * @var \KafkaApp\Kafka\Test\TestConsumerSwoole
      */
     protected $testConsumer;
 

src/Components/kafka/example/Process/WorkermanTestProcess.php

@@ -17,9 +17,9 @@
 class WorkermanTestProcess extends BaseProcess
 {
     /**
-     * @Inject("TestConsumer")
+     * @Inject("TestConsumerWorkerman")
      *
-     * @var \KafkaApp\Kafka\Test\TestConsumer
+     * @var \KafkaApp\Kafka\Test\TestConsumerWorkerman
      */
     protected $testConsumer;