// GetKafkaConsumer creates a Kafka consumer and sets the consumer flag to true
GetKafkaConsumer creates a Kafka consumer and sets the consumer flag to true
// GetKafkaConsumer creates a Kafka consumer and sets the consumer flag to true
func (e *ExternalServiceList) GetKafkaConsumer(ctx context.Context, cfg *config.Config) (dpkafka.IConsumerGroup, error) {
	consumer, err := e.Init.DoGetKafkaConsumer(ctx, &cfg.KafkaConfig)
	if err != nil {
		return nil, err
	}
	e.KafkaConsumer = true
	return consumer, nil
}
func ( e * ExternalServiceList ) GetKafkaConsumer ( ctx context . Context , cfg * config . Config ) ( dpkafka . IConsumerGroup , error ) { consumer , err := e . Init . DoGetKafkaConsumer ( ctx , & cfg . KafkaConfig ) if err != nil { return nil , err } e . KafkaConsumer = true return consumer , nil }
GetKafkaConsumer creates a Kafka consumer and sets the consumer flag to true
GetKafkaConsumer creates a Kafka consumer and sets the consumer flag to true