{"3 somelongkey=\n", nil, false},
		{"50 tooshort=\n", nil, false},
		{"13 key1=haha\n13 key2=nana\n13 key3=kaka\n",
			map[string]string{"key1": "haha", "key2": "nana", "key3": "kaka"}, true},
		{"13 key1=val1\n13 key2=val2\n8 key1=\n",
			map[string]string{"key1": "", "key2": "val2"}, true},
		{"22 GNU.sparse.size=10\n26 GNU.sparse.numblocks=2\n" +

	}
	return nil
}

// Name returns the name of the target
func (h *Target) Name() string {
	return "minio-kafka-audit"
}

// Endpoint - return kafka target
func (h *Target) Endpoint() string {
	return "kafka"
}

// String - kafka string
func (h *Target) String() string {
	return "kafka"
}

// Stats returns the target statistics.
func (h *Target) Stats() types.TargetStats {
	h.logChMu.RLock()

	EnvKafkaEnable                   = "MINIO_NOTIFY_KAFKA_ENABLE"
	EnvKafkaBrokers                  = "MINIO_NOTIFY_KAFKA_BROKERS"
	EnvKafkaTopic                    = "MINIO_NOTIFY_KAFKA_TOPIC"
	EnvKafkaQueueDir                 = "MINIO_NOTIFY_KAFKA_QUEUE_DIR"
	EnvKafkaQueueLimit               = "MINIO_NOTIFY_KAFKA_QUEUE_LIMIT"
	EnvKafkaTLS                      = "MINIO_NOTIFY_KAFKA_TLS"

// GNU Affero General Public License for more details.
//
// You should have received a copy of the GNU Affero General Public License
// along with this program.  If not, see <http://www.gnu.org/licenses/>.

package kafka

import (
	"crypto/sha512"
	"strings"

	"github.com/IBM/sarama"
	"github.com/xdg/scram"

	"github.com/minio/minio/internal/hash/sha256"
)

func initScramClient(cfg Config, config *sarama.Config) {

3b,QAAS4b,EAAYC,GAEhE,IAAIM,EAAa,SAAUC,GAQ1B,OAA0B,IAAnBA,EAAM/gB,UAAqC,IAAnB+gB,EAAM/gB,YAAsB+gB,EAAM/gB,UAMlE,SAASghB,IACRviB,KAAK+F,QAAU/C,EAAO+C,QAAUwc,EAAKC,MAGtCD,EAAKC,IAAM,EAEXD,EAAKhf,UAAY,CAEhB8K,MAAO,SAAUiU,GAGhB,IAAInb,EAAQmb,EAAOtiB,KAAK+F,SA4BxB,OAzBMoB,IACLA,EAAQ,GAKHkb,EAAYC,KAIXA,EAAM/gB,SACV+gB,EAAOtiB,KAAK+F,SAAYoB,EAMxB/G,OAAOqiB,eAAgBH,EAAOtiB,KAAK+F,QAAS,CAC3CoB,MAAOA,EACPub,cAAc,MAMXvb,GAERwb,IAAK,SAAUL,EAAOM,EAAMzb,GAC3B,IAAI0b,EACHxU,EAAQrO,KAAKqO,MAAOiU,GAIrB,GAAqB,iBAA...

      }
    }
  }
}
```

### Kafka Target

Assuming that you already have Apache Kafka configured and running.

```
mc admin config set myminio/ audit_kafka
KEY:
audit_kafka[:name]  send audit logs to kafka endpoints

ARGS:
brokers*         (csv)       comma separated list of Kafka broker addresses
topic            (string)    Kafka topic used for bucket notifications

3b,QAAS4b,EAAYC,GAEhE,IAAIM,EAAa,SAAUC,GAQ1B,OAA0B,IAAnBA,EAAM/gB,UAAqC,IAAnB+gB,EAAM/gB,YAAsB+gB,EAAM/gB,UAMlE,SAASghB,IACRviB,KAAK+F,QAAU/C,EAAO+C,QAAUwc,EAAKC,MAGtCD,EAAKC,IAAM,EAEXD,EAAKhf,UAAY,CAEhB8K,MAAO,SAAUiU,GAGhB,IAAInb,EAAQmb,EAAOtiB,KAAK+F,SA4BxB,OAzBMoB,IACLA,EAAQ,GAKHkb,EAAYC,KAIXA,EAAM/gB,SACV+gB,EAAOtiB,KAAK+F,SAAYoB,EAMxB/G,OAAOqiB,eAAgBH,EAAOtiB,KAAK+F,QAAS,CAC3CoB,MAAOA,EACPub,cAAc,MAMXvb,GAERwb,IAAK,SAAUL,EAAOM,EAAMzb,GAC3B,IAAI0b,EACHxU,EAAQrO,KAAKqO,MAAOiU,GAIrB,GAAqB,iBAA...

```

## Publish MinIO events via Kafka

Install Apache Kafka from [here](http://kafka.apache.org/).

### Step 1: Ensure minimum requirements are met

MinIO requires Kafka version 0.10 or 0.9. Internally MinIO uses the [Shopify/sarama](https://github.com/Shopify/sarama/) library and so has the same version compatibility as provided by this library.

### Step 2: Add Kafka endpoint to MinIO

	EnvKafkaEnable        = "MINIO_AUDIT_KAFKA_ENABLE"
	EnvKafkaBrokers       = "MINIO_AUDIT_KAFKA_BROKERS"
	EnvKafkaTopic         = "MINIO_AUDIT_KAFKA_TOPIC"
	EnvKafkaTLS           = "MINIO_AUDIT_KAFKA_TLS"
	EnvKafkaTLSSkipVerify = "MINIO_AUDIT_KAFKA_TLS_SKIP_VERIFY"
	EnvKafkaTLSClientAuth = "MINIO_AUDIT_KAFKA_TLS_CLIENT_AUTH"
	EnvKafkaSASLEnable    = "MINIO_AUDIT_KAFKA_SASL"
	EnvKafkaSASLUsername  = "MINIO_AUDIT_KAFKA_SASL_USERNAME"

		},
	}

	HelpKafka = config.HelpKVS{
		config.HelpKV{
			Key:         KafkaBrokers,
			Description: "comma separated list of Kafka broker addresses",
			Type:        "csv",
		},
		config.HelpKV{
			Key:         KafkaTopic,
			Description: "Kafka topic used for bucket notifications",
			Optional:    true,
			Type:        "string",
		},
		config.HelpKV{
			Key:         KafkaSASLUsername,