diff --git a/Kafka/Kafka.php b/Kafka/Kafka.php
index c62697e1..05ff9641 100644
--- a/Kafka/Kafka.php
+++ b/Kafka/Kafka.php
@@ -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;