iconsumer.go 213 B

1234567891011
  1. package kafka
  2. import (
  3. "git.beejay.kim/Craft/Api/service"
  4. lib "github.com/confluentinc/confluent-kafka-go/v2/kafka"
  5. )
  6. type Consumer interface {
  7. service.Service
  8. Subscribe([]string, chan *lib.Message) error
  9. }