改名

2020-12-28 17:28:56 +08:00
parent 2013129406
commit ad130c5512
1 changed files with 2 additions and 0 deletions
@@ -126,6 +126,8 @@ class Kafka extends \Snowflake\Process\Process
 	protected function handlerExecute($topic, $message)
 	{
 		try {
+			$topic = str_replace('-', '_', $topic);
+
 			$namespace = 'App\\Kafka\\' . ucfirst($topic) . 'Consumer';
 			if (!class_exists($namespace)) {
 				return;