kafka_golang

type ConcurrentRouter struct {
	Router KeyRouter
	sync.RWMutex
}

type Consumer interface {
	// Run starts the consumer. It is necessary to call this method, otherwise the Consumer
	// won't consume any events.
	Run() (stop chan bool, err error)
}

type Handler func(event *kafka.Message) error

type JSONProducer interface {
	// ProduceJSONSync produces a message without headers and key by JSON-encoding the given value.
	ProduceJSONSync(topic string, partition int32, value interface{}) error
}

type KeyRouter interface {
	Consumer
	// NewRoute registers a handler for the given key. Only one handler may exist per key.
	NewRoute(key catchall.Key, handler Handler)
	// Handle routes a single Event either to the appropriate Handler function or to a generic error handler.
	// Note that this method may block.
	Handle(event kafka.Event)
}

type LowLevelProducer interface {
	// ProduceSimpleSync sends a message without headers or key into a specific topic and partition.
	// It is mainly used for testing.
	ProduceSimpleSync(topic string, partition int32, value []byte) error
	// ProduceSync synchronously produces a Message.
	ProduceSync(message *kafka.Message) error
}

type Producer struct {
	Producer *kafka.Producer
}

type TopicRouter struct {
	*kafka.Consumer
	Handlers map[catchall.Key]Handler
}