code: func NewOptions() *Options {
  	return &Options{
  		Brokers:           []string{"localhost:9092"},
  		Topic:             "graphite",
  		Partition:         0,
  		Protocol:          ProtocolPlain,
  		InitialOffset:     OffsetOldest,
  		StateSaveInterval: &Duration{Duration: 60 * time.Second},
  		ReconnectInterval: &Duration{Duration: 60 * time.Second},
  		FetchInterval:     &Duration{Duration: 250 * time.Millisecond},
  		KafkaVersion:      "0.11.0.0",
  	}
  }
docs: // NewOptions returns Options struct filled with default values.