- job_record.Job_control = make(chan dataTypes.JobControl, 1)
- job_record.Reader_control = make(chan dataTypes.ReaderControl, 1)
- job_record.Data_in_channel = make(chan *dataTypes.KafkaPayload, reader_queue_length)
- job_record.InfoType = dp.ID
- job_record.InputTopic = dp.KafkaInputTopic
- job_record.GroupId = "kafka-procon-" + dp.ID
- job_record.ClientId = dp.ID + "-" + os.Getenv("KP")
+ jobRecord.Job_control = make(chan dataTypes.JobControl, 1)
+ jobRecord.Reader_control = make(chan dataTypes.ReaderControl, 1)
+ jobRecord.Data_in_channel = make(chan *dataTypes.KafkaPayload, reader_queue_length)
+ jobRecord.InfoType = dp.ID
+ jobRecord.InputTopic = dp.KafkaInputTopic
+ jobRecord.GroupId = "kafka-procon-" + dp.ID
+ jobRecord.ClientId = dp.ID + "-" + os.Getenv("KP")