// NewKafkaSeeker creates an instance of KafkaSeeker
NewKafkaSeeker creates an instance of KafkaSeeker
// NewKafkaSeeker creates an instance of KafkaSeeker
func NewKafkaSeeker(addr []string, config *sarama.Config) (*KafkaSeeker, error) {
	client, err := sarama.NewClient(addr, config)
	if err != nil {
		return nil, errors.Trace(err)
	}
	consumer, err := sarama.NewConsumerFromClient(client)
	if err != nil {
		return nil, errors.Trace(err)
	}
	s := &KafkaSeeker{
		client:   client,
		consumer: consumer,
	}
	return s, nil
}
func NewKafkaSeeker ( addr [ ] string , config * sarama . Config ) ( * KafkaSeeker , error ) { client , err := sarama . NewClient ( addr , config ) if err != nil { return nil , errors . Trace ( err ) } consumer , err := sarama . NewConsumerFromClient ( client ) if err != nil { return nil , errors . Trace ( err ) } s := & KafkaSeeker { client : client , consumer : consumer , } return s , nil }
NewKafkaSeeker creates an instance of KafkaSeeker
NewKafkaSeeker creates an instance of KafkaSeeker