Handler defines the interface for message processing
| 26 | |
| 27 | // Handler defines the interface for message processing |
| 28 | type Handler interface { |
| 29 | Handle(ctx context.Context, msg *sarama.ConsumerMessage) error |
| 30 | } |
| 31 | |
| 32 | // NewProducer creates a new Kafka producer |
| 33 | func NewProducer(config *configs.Config) (Producer, error) { |
nothing calls this directly
no outgoing calls
no test coverage detected