receiver/kafka/kafka.go
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",
	}
}
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",
	}
}
func NewOptions ( ) * Options { return & Options { Brokers : [ ] string { " " } , Topic : " " , 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 : " " , } }
// NewOptions returns Options struct filled with default values.
NewOptions returns Options struct filled with default values .