kafka

type Option func(options *Options)

type Options struct {
	ClusterConfig cluster.Config

	// IsSynchronous type of producer
	// TODO: make it work for sync publisher
	IsSynchronous bool

	// Brokers contains list of broker hosts with port
	Brokers []string

	// Name of the subscription group
	GroupName string

	// Names of topics for subscribing or publishing
	Topics []string

	// ErrorHandler of message processing
	ErrorHandler nc.ErrorHandler

	// PanicHandler process panic
	PanicHandler nc.PanicHandler

	// PublisherErrorHandler provides handler of message send errors
	PublisherErrorHandler PublisherErrorHandler

	// PublisherSuccessHandler provides handler of message send success
	PublisherSuccessHandler PublisherSuccessHandler

	// SubscriberNotificationHandler provides handler of received messages
	SubscriberNotificationHandler SubscriberNotificationHandler

	// Message encoder interface
	Encoder encoder.Encoder

	// Logger of subscriber
	Logger loggerInterface
}

type Publisher struct {
	// contains filtered or unexported fields
}

type PublisherErrorHandler func(*sarama.ProducerError)

type PublisherSuccessHandler func(*sarama.ProducerMessage)

type Subscriber struct {
	notificationcenter.ModelSubscriber
	// contains filtered or unexported fields
}

type SubscriberNotificationHandler func(notification *cluster.Notification)