package main

import (
	"dsDataex/MyTask/Kafka2ES/Kafka2ESService"
	"fmt"
	"time"
)

var ChanCount chan int
var Count =0

func main() {

	fmt.Println("Kafka2ES Service & Task Start !!!")

	//s1 := gocron.NewScheduler(time.UTC)
	//
	//s1.Every(5).Seconds().Do(proc)
	//s1.Every(5).Seconds().Do(proc)
	//s1.StartBlocking()

	//go proc()
	//go proc()
	//time.Sleep(60 * time.Minute)

	Kafka2ESService.ServiceStart()
}

func proc() {
	for no:=0;no<1000;no++{
		Count++
		fmt.Println("Count :",Count)
		time.Sleep(1 * time.Millisecond)
	}
}