diff --git a/config/default-slack-delete.tmpl b/config/default-slack-delete.tmpl
index cb05da25..e8adfc68 100644
--- a/config/default-slack-delete.tmpl
+++ b/config/default-slack-delete.tmpl
@@ -1 +1,30 @@
-{ "attachments": [{"color": "good","title": "A kafka consumer is has caught up his lag","fields": [{"title": "Group","value": "{{ .Group }}", "short": false},{"title": "Cluster","value": "{{ .Cluster }}","short": true},{"title": "Total Lag","value": "{{ .Result.TotalLag}}","short": true}, {"title": "Start","value": "{{ .Start.Format "2006-01-02T15:04:05Z07:00" }}","short": true}]}]}
+{
+  "attachments": [
+    {
+      "fields": [
+        {
+          "short": false,
+          "value": "{{ .Group }}",
+          "title": "Group"
+        },
+        {
+          "short": true,
+          "value": "{{ .Cluster }}",
+          "title": "Cluster"
+        },
+        {
+          "short": true,
+          "value": "{{ .Result.TotalLag}}",
+          "title": "Total Lag"
+        },
+        {
+          "short": true,
+          "value": " {{ .Start.Format "2006-01-02T15:04:05Z07:00" }}",
+          "title": "Start"
+        }
+      ],
+      "title": "A kafka consumer is no longer lagging",
+      "color": "good"
+     }
+  ]
+}
diff --git a/config/default-slack-post.tmpl b/config/default-slack-post.tmpl
index ddffa338..df6d66bb 100644
--- a/config/default-slack-post.tmpl
+++ b/config/default-slack-post.tmpl
@@ -1 +1,30 @@
-{ "attachments": [{"color": "danger","title": "A kafka consumer is lagging behind!","fields": [{"title": "Group","value": "{{ .Group }}", "short": false},{"title": "Cluster","value": "{{ .Cluster }}","short": true},{"title": "Total Lag","value": "{{ .Result.TotalLag}}","short": true}, {"title": "Start","value": "{{ .Start.Format "2006-01-02T15:04:05Z07:00" }}","short": true}]}]}
+{
+  "attachments": [
+    {
+      "fields": [
+        {
+          "short": false,
+          "value": "{{ .Group }}",
+          "title": "Group"
+        },
+        {
+          "short": true,
+          "value": "{{ .Cluster }}",
+          "title": "Cluster"
+        },
+        {
+          "short": true,
+          "value": "{{ .Result.TotalLag}}",
+          "title": "Total Lag"
+        },
+        {
+          "short": true,
+          "value": " {{ .Start.Format "2006-01-02T15:04:05Z07:00" }}",
+          "title": "Start"
+        }
+      ],
+      "title": "A kafka consumer is lagging behind!",
+      "color": "danger"
+     }
+  ]
+}
diff --git a/core/internal/helpers/sarama.go b/core/internal/helpers/sarama.go
index 492d7b0a..5ee36724 100644
--- a/core/internal/helpers/sarama.go
+++ b/core/internal/helpers/sarama.go
@@ -38,7 +38,7 @@ func parseKafkaVersion(kafkaVersion string) sarama.KafkaVersion {
 		return sarama.V0_10_0_1
 	case "0.10.1", "0.10.1.0":
 		return sarama.V0_10_1_0
-	case "", "0.10.2", "0.10.2.0":
+	case "", "0.10.2", "0.10.2.0", "0.10.2.1":
 		return sarama.V0_10_2_0
 	case "0.11.0", "0.11.0.1", "0.11.0.2":
 		return sarama.V0_11_0_0