pubsub.go

/*
Package kafka_go is an abstraction over popular kafka client sarama (https://github.com/Shopify/sarama).
Though sarama provides good enough APIs to integrate with a kafka cluster but still lags simplicity and
need a bit of domain knowledge even for a standard use case. End user has to maintain fail safety, reclaim
after re-balancing or similar scenarios, API doesn't seems very intuitive for the first time kafka users.
kafka_go tries to solves all such problems with its easy to understand APIs to start consuming from a kafka
cluster with significant less domain knowledge and complete fail safety.

Note: this package implements at-least once analogy of message consumption, user will have to maintain idempotence on
their own.
*/
package kafka_go

import (
	"log"
	"os"
)

var (
	// Logger is the kafka-go package single logger instance. It logs most important
	// event during the process of message consumption and production. This logger
	// can be overridden to complete stop any sort of logs to be printed on standard output
	// example:
	// Logger = log.New(ioutil.Discard, "[kafka-go]", log.LstdFlags)
	// above will discard all the logs printed by kafka-go logger
	Logger = log.New(os.Stdout, "[kafka-go]", log.LstdFlags)
)