package main

import (
	"dsDataex/MyTask/Kafka2ES/Kafka2ESService"
	"dsDataex/Utils/CacheUtil"
	"fmt"
)

func main() {
	fmt.Println("Kafka2ES Task Two Start !!!")

	CacheUtil.OrgtreeCacheInit()

	Kafka2ESService.GROUP_NO=2

	Kafka2ESService.ServiceStart()
}