processor

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

type KafkaProcessorConfig struct {
	BrokerUrls      []string
	ClientID        string
	NewConsumerFunc func(cfg *consumer.KafkaConsumerConfig) consumer.TransactionConsumer
	DetectionTime   time.Duration
	UseCase         transactionsUseCase.UseCase
	Logger          *zerolog.Logger
}

type ProcessorError string