File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -60,14 +60,14 @@ public function handle(HighLevelConsumer $highLevelConsumer): int
60
60
$ processorData = $ this ->findMatchedProcessor ($ topicKey , $ consumer );
61
61
if (is_null ($ processorData )) {
62
62
$ this ->error ("Processor for topic-key \"$ topicKey \" and consumer \"$ consumer \" is not found " );
63
- $ this ->line ('Processors are set in /config/kafka-consumers .php ' );
63
+ $ this ->line ('Processors are set in /config/kafka-consumer .php ' );
64
64
65
65
return 1 ;
66
66
}
67
67
68
68
if (!class_exists ($ processorData ->class )) {
69
69
$ this ->error ("Processor class \"$ processorData ->class \" is not found " );
70
- $ this ->line ('Processors are set in /config/kafka-consumers .php ' );
70
+ $ this ->line ('Processors are set in /config/kafka-consumer .php ' );
71
71
72
72
return 1 ;
73
73
}
You can’t perform that action at this time.
0 commit comments