jgeek

The CLI have many options, but here are the other that are most commonly used:

Producer with keys

kafka-console-producer --broker-list 127.0.0.1:9092 --topic first_topic --property parse.key=true --property key.separator=,
> key,value
> another key,another value
Consumer with keys
--------

jgeek

If you have two days to learn the very basics of modelling, Domain-Driven Design, CQRS and Event Sourcing, here's what you should do:

In the evenings read the [Domain-Driven Design Quickly Minibook]{http://www.infoq.com/minibooks/domain-driven-design-quickly}. During the day watch following great videos (in this order):

1. Eric Evans' [What I've learned about DDD since the book]{http://www.infoq.com/presentations/ddd-eric-evans}
2. Eric Evans' [Strategic Design - Responsibility Traps]{http://www.infoq.com/presentations/design-strategic-eric-evans}
3. Udi Dahan's [Avoid a Failed SOA: Business & Autonomous Components to the Rescue]{http://www.infoq.com/presentations/SOA-Business-Autonomous-Components}
4. Udi Dahan's [Command-Query Responsibility Segregation]{http://www.infoq.com/presentations/Command-Query-Responsibility-Segregation}
5. Greg Young's [Unshackle Your Domain]{http://www.infoq.com/presentations/greg-young-unshackle-qcon08}
6. Eric Evans' [Acknowledging CAP at the Root -- in the Domain Model]{ht

jgeek

shards and reps
text field : ignore above
set 'doc_values'/'norms'/'index' for false to save disk if not necessary
set 'doc_values' to false: if sorting, scrpting and aggregation are not needed
setting norms to false: if relevance scoring is not needed
setting index to false: if do not need to filtering on values. still can be use for aggregation (time series) 
set dynamic_mapping to strict
dont always map strings to text and keyword
disable corecion
integer is enough than long and float often cover our need instead of double

jgeek

db.createUser(
  {
    user: "da",
    pwd: "da@dp",
    roles: [ { role: "root", db: "admin" } ]
  }
)

jgeek

package main

import (
	"bytes"
	"compress/gzip"
	"fmt"
	"encoding/base64"
	"io/ioutil"
)