diff --git a/src/scala/ly/stealth/mesos/kafka/Config.scala b/src/scala/ly/stealth/mesos/kafka/Config.scala
index fbde1b4..a7dfa3b 100644
--- a/src/scala/ly/stealth/mesos/kafka/Config.scala
+++ b/src/scala/ly/stealth/mesos/kafka/Config.scala
@@ -38,6 +38,8 @@ object Config {
   var frameworkRole: String = "*"
   var frameworkTimeout: Period = new Period("30d")
 
+  var taskName: String = "executor"
+
   var jre: File = null
   var log: File = null
   var api: String = null
diff --git a/src/scala/ly/stealth/mesos/kafka/Scheduler.scala b/src/scala/ly/stealth/mesos/kafka/Scheduler.scala
index abfb5f8..c848db0 100644
--- a/src/scala/ly/stealth/mesos/kafka/Scheduler.scala
+++ b/src/scala/ly/stealth/mesos/kafka/Scheduler.scala
@@ -100,7 +100,7 @@ object Scheduler extends org.apache.mesos.Scheduler {
     }
 
     val taskBuilder: TaskInfo.Builder = TaskInfo.newBuilder
-      .setName(Config.frameworkName + "-" + broker.id)
+      .setName(Config.frameworkName + "-" + Config.taskName)
       .setTaskId(TaskID.newBuilder.setValue(Broker.nextTaskId(broker)).build)
       .setSlaveId(offer.getSlaveId)
       .setData(taskData)