code: func New(brokers []string, topic, group string) *KafkaSource {
  	return &KafkaSource{
  		Brokers:        brokers,
  		Topic:          topic,
  		Group:          group,
  		TimeoutSeconds: 16,
  
  		prefix: topic,
  	}
  }
docs: /*
  This file is only for the builder API.
  */