how-to-use-kafka-cronsumer.go

func main() {
        // ..
	var consumeFn kafka.ConsumeFn = func(message kafka.Message) error {
		fmt.Printf("consumer > Message received: %s\n", string(message.Value))
		return nil
	}

	c := cronsumer.New(kafkaConfig, consumeFn)
	c.Run()
}